//===----------------------------------------------------------------------===// // DuckDB // // duckdb/execution/operator/helper/physical_materialized_collector.hpp // // //===----------------------------------------------------------------------===// #pragma once #include "duckdb/execution/operator/helper/physical_result_collector.hpp" namespace duckdb { class PhysicalMaterializedCollector : public PhysicalResultCollector { public: PhysicalMaterializedCollector(PreparedStatementData &data, bool parallel); bool parallel; public: unique_ptr GetResult(GlobalSinkState &state) override; public: // Sink interface SinkResultType Sink(ExecutionContext &context, DataChunk &chunk, OperatorSinkInput &input) const override; void Combine(ExecutionContext &context, GlobalSinkState &gstate, LocalSinkState &lstate) const override; unique_ptr GetLocalSinkState(ExecutionContext &context) const override; unique_ptr GetGlobalSinkState(ClientContext &context) const override; bool ParallelSink() const override; bool SinkOrderDependent() const override; }; } // namespace duckdb