| 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 | /// |
no outgoing calls
no test coverage detected