Move code

r/DESCRIPTION

@@ -78,4 +78,5 @@ Collate:
     'read_table.R'
     'reexports-bit64.R'
     'reexports-tidyselect.R'
+    'to-arrow.R'
     'write_arrow.R'

r/R/Table.R

@@ -65,24 +65,6 @@
   )
 )
 
-#' Create an arrow::Table from a data frame
-#'
-#' @param ... arrays, chunked arrays, or R vectors
-#' @param schema a schema. The default (`NULL`) infers the schema from the `...`
-#'
-#' @return an arrow::Table
-#'
-#' @export
-table <- function(..., schema = NULL){
-  dots <- list2(...)
-  # making sure there are always names
-  if (is.null(names(dots))) {
-    names(dots) <- rep_len("", length(dots))
-  }
-  stopifnot(length(dots) > 0)
-  shared_ptr(`arrow::Table`, Table__from_dots(dots, schema))
-}
-
 #' @export
 `as.data.frame.arrow::Table` <- function(x, row.names = NULL, optional = FALSE, use_threads = TRUE, ...){
   Table__to_dataframe(x, use_threads = option_use_threads())

r/R/array.R

@@ -147,13 +147,3 @@
 
 #' @export
 `==.arrow::Array` <- function(x, y) x$Equals(y)
-
-#' create an [arrow::Array][arrow__Array] from an R vector
-#'
-#' @param x R object
-#' @param type Explicit [type][arrow__DataType], or NULL (the default) to infer from the data
-#'
-#' @export
-array <- function(x, type = NULL){
-  `arrow::Array`$dispatch(Array__from_vector(x, type))
-}

r/R/to-arrow.R

@@ -0,0 +1,38 @@
+to_arrow <- function(x) {
+  UseMethod("to_arrow")
+}
+
+`to_arrow.arrow::RecordBatch` <- function(x) x
+`to_arrow.arrow::Table` <- function(x) x
+
+# splice the data frame as arguments of table()
+# see ?rlang::list2()
+`to_arrow.data.frame` <- function(x) table(!!!x)
+
+#' Create an arrow::Table from a data frame
+#'
+#' @param ... arrays, chunked arrays, or R vectors
+#' @param schema a schema. The default (`NULL`) infers the schema from the `...`
+#'
+#' @return an arrow::Table
+#'
+#' @export
+table <- function(..., schema = NULL){
+  dots <- list2(...)
+  # making sure there are always names
+  if (is.null(names(dots))) {
+    names(dots) <- rep_len("", length(dots))
+  }
+  stopifnot(length(dots) > 0)
+  shared_ptr(`arrow::Table`, Table__from_dots(dots, schema))
+}
+
+#' create an [arrow::Array][arrow__Array] from an R vector
+#'
+#' @param x R object
+#' @param type Explicit [type][arrow__DataType], or NULL (the default) to infer from the data
+#'
+#' @export
+array <- function(x, type = NULL){
+  `arrow::Array`$dispatch(Array__from_vector(x, type))
+}

r/R/write_arrow.R

@@ -15,17 +15,6 @@
 # specific language governing permissions and limitations
 # under the License.
 
-to_arrow <- function(x) {
-  UseMethod("to_arrow")
-}
-
-`to_arrow.arrow::RecordBatch` <- function(x) x
-`to_arrow.arrow::Table` <- function(x) x
-
-# splice the data frame as arguments of table()
-# see ?rlang::list2()
-`to_arrow.data.frame` <- function(x) table(!!!x)
-
 #' Write Arrow formatted data
 #'
 #' @param x an [arrow::Table][arrow__Table], an [arrow::RecordBatch][arrow__RecordBatch] or a data.frame