RecordBatchFileWriter
and RecordBatchStreamWriter
are
interfaces for writing record batches to either the binary file or streaming
format.
writer <- RecordBatchStreamWriter$create(sink, schema) writer$write_batch(batch) writer$write_table(table) writer$close()
The RecordBatchFileWriter$create()
and RecordBatchStreamWriter$create()
factory methods instantiate the object and
take a single argument, named according to the class:
sink
A character file name or an OutputStream
.
schema
A Schema for the data to be written.
$write(x)
: Write a RecordBatch, Table, or data.frame
, dispatching
to the methods below appropriately
$write_batch(batch)
: Write a RecordBatch
to stream
$write_table(table)
: Write a Table
to stream
$close()
: close stream
arrow::Object
-> RecordBatchWriter
write_batch()
RecordBatchWriter$write_batch(batch)
write_table()
RecordBatchWriter$write_table(table)
write()
RecordBatchWriter$write(x)
close()
RecordBatchWriter$close()
clone()
The objects of this class are cloneable with this method.
RecordBatchWriter$clone(deep = FALSE)
deep
Whether to make a deep clone.
arrow::Object
-> arrow::RecordBatchWriter
-> RecordBatchStreamWriter
clone()
The objects of this class are cloneable with this method.
RecordBatchStreamWriter$clone(deep = FALSE)
deep
Whether to make a deep clone.
arrow::Object
-> arrow::RecordBatchWriter
-> arrow::RecordBatchStreamWriter
-> RecordBatchFileWriter
clone()
The objects of this class are cloneable with this method.
RecordBatchFileWriter$clone(deep = FALSE)
deep
Whether to make a deep clone.