27 using StreamerCreator = std::function<std::shared_ptr<arrow::io::OutputStream>(std::shared_ptr<arrow::dataset::FileFragment>,
const std::shared_ptr<arrow::ResizableBuffer>&
buffer)>;
31 void fill(std::shared_ptr<arrow::Schema> dataSetSchema, std::shared_ptr<arrow::dataset::FileFormat>);
32 std::shared_ptr<arrow::RecordBatch>
finalize();
34 std::shared_ptr<arrow::io::OutputStream>
streamer(std::shared_ptr<arrow::ResizableBuffer>
buffer)
36 return mCreator(mFragment,
buffer);
40 std::shared_ptr<arrow::dataset::FileFragment> mFragment;
41 arrow::MemoryPool* mArrowMemoryPool =
nullptr;
42 std::string mTableLabel;
43 std::shared_ptr<arrow::RecordBatch> mRecordBatch;