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

Function SinkNodeOptions

cpp/src/arrow/acero/options.h:416–424  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

414 sequence_output(sequence_output) {}
415
416 explicit SinkNodeOptions(std::function<Future<std::optional<ExecBatch>>()>* generator,
417 BackpressureOptions backpressure = {},
418 BackpressureMonitor** backpressure_monitor = NULLPTR,
419 std::optional<bool> sequence_output = std::nullopt)
420 : generator(generator),
421 schema(NULLPTR),
422 backpressure(std::move(backpressure)),
423 backpressure_monitor(backpressure_monitor),
424 sequence_output(sequence_output) {}
425
426 /// \brief A pointer to a generator of batches.
427 ///

Callers 1

Calls

no outgoing calls

Tested by

no test coverage detected