MCPcopy Create free account
hub / github.com/apache/arrow / MakeStreamWriter

Function MakeStreamWriter

cpp/src/arrow/ipc/writer.cc:1536–1542  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1534} // namespace internal
1535
1536Result<std::shared_ptr<RecordBatchWriter>> MakeStreamWriter(
1537 io::OutputStream* sink, const std::shared_ptr<Schema>& schema,
1538 const IpcWriteOptions& options) {
1539 return std::make_shared<internal::IpcFormatWriter>(
1540 std::make_unique<internal::PayloadStreamWriter>(sink, options), schema, options,
1541 /*is_file_format=*/false);
1542}
1543
1544Result<std::shared_ptr<RecordBatchWriter>> MakeStreamWriter(
1545 std::shared_ptr<io::OutputStream> sink, const std::shared_ptr<Schema>& schema,

Callers 7

ReadStreamFunction · 0.85
DecodeStreamFunction · 0.85
InitMethod · 0.85
SerializeRecordBatchFunction · 0.85
WriteRecordBatchStreamFunction · 0.85

Calls

no outgoing calls

Tested by 1

InitMethod · 0.68