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.

Object Safety

This trait is not object safe.

Implementors

impl ExecutorBuilder for AppendOnlyDedupExecutorBuilder

type Node = DedupNode

impl ExecutorBuilder for GlobalApproxPercentileExecutorBuilder

type Node = GlobalApproxPercentileNode

impl ExecutorBuilder for LocalApproxPercentileExecutorBuilder

type Node = LocalApproxPercentileNode

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 EowcOverWindowExecutorBuilder

type Node = EowcOverWindowNode

impl ExecutorBuilder for ExpandExecutorBuilder

type Node = ExpandNode

impl ExecutorBuilder for FilterExecutorBuilder

type Node = FilterNode

impl ExecutorBuilder for HashAggExecutorBuilder

type Node = HashAggNode

impl ExecutorBuilder for HashJoinExecutorBuilder

type Node = HashJoinNode

impl ExecutorBuilder for HopWindowExecutorBuilder

type Node = HopWindowNode

impl ExecutorBuilder for LookupExecutorBuilder

type Node = LookupNode

impl ExecutorBuilder for LookupUnionExecutorBuilder

type Node = LookupUnionNode

impl ExecutorBuilder for MergeExecutorBuilder

type Node = MergeNode

impl ExecutorBuilder for ArrangeExecutorBuilder

type Node = ArrangeNode

impl ExecutorBuilder for MaterializeExecutorBuilder

type Node = MaterializeNode

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 FsFetchExecutorBuilder

type Node = StreamFsFetchNode

impl ExecutorBuilder for SourceExecutorBuilder

type Node = SourceNode

impl ExecutorBuilder for SourceBackfillExecutorBuilder

type Node = SourceBackfillNode

impl ExecutorBuilder for StatelessSimpleAggExecutorBuilder

type Node = SimpleAggNode

impl ExecutorBuilder for StreamCdcScanExecutorBuilder

type Node = StreamCdcScanNode

impl ExecutorBuilder for StreamScanExecutorBuilder

type Node = StreamScanNode

impl ExecutorBuilder for TemporalJoinExecutorBuilder

type Node = TemporalJoinNode

impl ExecutorBuilder for UnionExecutorBuilder

type Node = UnionNode

impl ExecutorBuilder for ValuesExecutorBuilder

type Node = ValuesNode

impl ExecutorBuilder for WatermarkFilterBuilder

type Node = WatermarkFilterNode

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