Trait ExecutorBuilder 

trait ExecutorBuilder {
    type Node;

    // Required method
    async fn new_boxed_executor(
        params: ExecutorParams,
        node: &Self::Node,
        store: impl StateStore,
    ) -> StreamResult<Executor>;
}

Required Associated Types

type Node

Required Methods

async fn new_boxed_executor( params: ExecutorParams, node: &Self::Node, store: impl StateStore, ) -> StreamResult<Executor>

Create an Executor from StreamNode.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl ExecutorBuilder for AppendOnlyDedupExecutorBuilder

type Node = DedupNode

impl ExecutorBuilder for ArrangeExecutorBuilder

type Node = ArrangeNode

impl ExecutorBuilder for AsOfJoinExecutorBuilder

type Node = AsOfJoinNode

impl ExecutorBuilder for BarrierRecvExecutorBuilder

type Node = BarrierRecvNode

impl ExecutorBuilder for BatchQueryExecutorBuilder

type Node = BatchPlanNode

impl ExecutorBuilder for CdcFilterExecutorBuilder

CdcFilter is an extension to the Filter executor

type Node = CdcFilterNode

impl ExecutorBuilder for ChangeLogExecutorBuilder

type Node = ChangeLogNode

impl ExecutorBuilder for DmlExecutorBuilder

type Node = DmlNode

impl ExecutorBuilder for DynamicFilterExecutorBuilder

type Node = DynamicFilterNode

impl ExecutorBuilder for EowcGapFillExecutorBuilder

type Node = EowcGapFillNode

impl ExecutorBuilder for EowcOverWindowExecutorBuilder

type Node = EowcOverWindowNode

impl ExecutorBuilder for ExpandExecutorBuilder

type Node = ExpandNode

impl ExecutorBuilder for FilterExecutorBuilder

type Node = FilterNode

impl ExecutorBuilder for FsFetchExecutorBuilder

type Node = StreamFsFetchNode

impl ExecutorBuilder for GapFillExecutorBuilder

type Node = GapFillNode

impl ExecutorBuilder for GlobalApproxPercentileExecutorBuilder

type Node = GlobalApproxPercentileNode

impl ExecutorBuilder for HashAggExecutorBuilder

type Node = HashAggNode

impl ExecutorBuilder for HashJoinExecutorBuilder

type Node = HashJoinNode

impl ExecutorBuilder for HopWindowExecutorBuilder

type Node = HopWindowNode

impl ExecutorBuilder for IcebergWithPkIndexDvMergerExecutorBuilder

type Node = IcebergWithPkIndexDvMergerNode

impl ExecutorBuilder for IcebergWithPkIndexWriterExecutorBuilder

type Node = IcebergWithPkIndexWriterNode

impl ExecutorBuilder for LocalApproxPercentileExecutorBuilder

type Node = LocalApproxPercentileNode

impl ExecutorBuilder for LocalityProviderBuilder

type Node = LocalityProviderNode

impl ExecutorBuilder for LookupExecutorBuilder

type Node = LookupNode

impl ExecutorBuilder for LookupUnionExecutorBuilder

type Node = LookupUnionNode

impl ExecutorBuilder for MaterializeExecutorBuilder

type Node = MaterializeNode

impl ExecutorBuilder for MaterializedExprsExecutorBuilder

type Node = MaterializedExprsNode

impl ExecutorBuilder for MergeExecutorBuilder

type Node = MergeNode

impl ExecutorBuilder for NoOpExecutorBuilder

type Node = NoOpNode

impl ExecutorBuilder for NowExecutorBuilder

type Node = NowNode

impl ExecutorBuilder for OverWindowExecutorBuilder

type Node = OverWindowNode

impl ExecutorBuilder for ProjectExecutorBuilder

type Node = ProjectNode

impl ExecutorBuilder for ProjectSetExecutorBuilder

type Node = ProjectSetNode

impl ExecutorBuilder for RowIdGenExecutorBuilder

type Node = RowIdGenNode

impl ExecutorBuilder for RowMergeExecutorBuilder

type Node = RowMergeNode

impl ExecutorBuilder for SimpleAggExecutorBuilder

type Node = SimpleAggNode

impl ExecutorBuilder for SinkExecutorBuilder

type Node = SinkNode

impl ExecutorBuilder for SortExecutorBuilder

type Node = SortNode

impl ExecutorBuilder for SourceBackfillExecutorBuilder

type Node = SourceBackfillNode

impl ExecutorBuilder for SourceExecutorBuilder

type Node = SourceNode

impl ExecutorBuilder for StatelessSimpleAggExecutorBuilder

type Node = SimpleAggNode

impl ExecutorBuilder for StreamCdcScanExecutorBuilder

type Node = StreamCdcScanNode

impl ExecutorBuilder for StreamScanExecutorBuilder

type Node = StreamScanNode

impl ExecutorBuilder for SyncLogStoreExecutorBuilder

type Node = SyncLogStoreNode

impl ExecutorBuilder for TemporalJoinExecutorBuilder

type Node = TemporalJoinNode

impl ExecutorBuilder for UnionExecutorBuilder

type Node = UnionNode

impl ExecutorBuilder for UpstreamSinkUnionExecutorBuilder

type Node = UpstreamSinkUnionNode

impl ExecutorBuilder for ValuesExecutorBuilder

type Node = ValuesNode

impl ExecutorBuilder for VectorIndexLookupJoinBuilder

type Node = VectorIndexLookupJoinNode

impl ExecutorBuilder for VectorIndexWriteExecutorBuilder

type Node = VectorIndexWriteNode

impl ExecutorBuilder for WatermarkFilterBuilder

type Node = WatermarkFilterNode

impl<T> ExecutorBuilder for UnreachableExecutorBuilder<T>

type Node = T

impl<const APPEND_ONLY: bool> ExecutorBuilder for GroupTopNExecutorBuilder<APPEND_ONLY>

type Node = GroupTopNNode

impl<const APPEND_ONLY: bool> ExecutorBuilder for TopNExecutorBuilder<APPEND_ONLY>

type Node = TopNNode