Function ipc___RecordBatchStreamWriter__Open

r/src/recordbatchwriter.cpp:55–64

[[arrow::export]]

// [[arrow::export]]
std::shared_ptr<arrow::ipc::RecordBatchWriter> ipc___RecordBatchStreamWriter__Open(
    const std::shared_ptr<arrow::io::OutputStream>& stream,
    const std::shared_ptr<arrow::Schema>& schema, bool use_legacy_format,
    arrow::ipc::MetadataVersion metadata_version) {
  auto options = arrow::ipc::IpcWriteOptions::Defaults();
  options.write_legacy_ipc_format = use_legacy_format;
  options.metadata_version = metadata_version;
  options.memory_pool = gc_memory_pool();
  return ValueOrStop(MakeStreamWriter(stream, schema, options));
}