Trait StreamNodeBody 

trait StreamNodeBody {
    type Node;
    type ExecutorBuilder: ExecutorBuilder<Node = Self::Node>;
}

Required Associated Types

type Node

type ExecutorBuilder: ExecutorBuilder<Node = Self::Node>

Dyn Compatibility

This trait is dyn compatible.

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

Implementations on Foreign Types

impl StreamNodeBody for AppendOnlyDedupVariant

type Node = DedupNode

type ExecutorBuilder = AppendOnlyDedupExecutorBuilder

impl StreamNodeBody for AppendOnlyGroupTopNVariant

type Node = GroupTopNNode

type ExecutorBuilder = GroupTopNExecutorBuilder<true>

impl StreamNodeBody for AppendOnlyTopNVariant

type Node = TopNNode

type ExecutorBuilder = TopNExecutorBuilder<true>

impl StreamNodeBody for ArrangeVariant

type Node = ArrangeNode

type ExecutorBuilder = ArrangeExecutorBuilder

impl StreamNodeBody for AsOfJoinVariant

type Node = AsOfJoinNode

type ExecutorBuilder = AsOfJoinExecutorBuilder

impl StreamNodeBody for BarrierRecvVariant

type Node = BarrierRecvNode

type ExecutorBuilder = BarrierRecvExecutorBuilder

impl StreamNodeBody for BatchPlanVariant

type Node = BatchPlanNode

type ExecutorBuilder = BatchQueryExecutorBuilder

impl StreamNodeBody for CdcFilterVariant

type Node = CdcFilterNode

type ExecutorBuilder = CdcFilterExecutorBuilder

impl StreamNodeBody for ChangelogVariant

type Node = ChangeLogNode

type ExecutorBuilder = ChangeLogExecutorBuilder

impl StreamNodeBody for DeltaIndexJoinVariant

type Node = DeltaIndexJoinNode

type ExecutorBuilder = UnreachableExecutorBuilder<DeltaIndexJoinNode>

impl StreamNodeBody for DmlVariant

type Node = DmlNode

type ExecutorBuilder = DmlExecutorBuilder

impl StreamNodeBody for DynamicFilterVariant

type Node = DynamicFilterNode

type ExecutorBuilder = DynamicFilterExecutorBuilder

impl StreamNodeBody for EowcGapFillVariant

type Node = EowcGapFillNode

type ExecutorBuilder = EowcGapFillExecutorBuilder

impl StreamNodeBody for EowcOverWindowVariant

type Node = EowcOverWindowNode

type ExecutorBuilder = EowcOverWindowExecutorBuilder

impl StreamNodeBody for ExchangeVariant

type Node = ExchangeNode

type ExecutorBuilder = UnreachableExecutorBuilder<ExchangeNode>

impl StreamNodeBody for ExpandVariant

type Node = ExpandNode

type ExecutorBuilder = ExpandExecutorBuilder

impl StreamNodeBody for FilterVariant

type Node = FilterNode

type ExecutorBuilder = FilterExecutorBuilder

impl StreamNodeBody for GapFillVariant

type Node = GapFillNode

type ExecutorBuilder = GapFillExecutorBuilder

impl StreamNodeBody for GlobalApproxPercentileVariant

type Node = GlobalApproxPercentileNode

type ExecutorBuilder = GlobalApproxPercentileExecutorBuilder

impl StreamNodeBody for GroupTopNVariant

type Node = GroupTopNNode

type ExecutorBuilder = GroupTopNExecutorBuilder<false>

impl StreamNodeBody for HashAggVariant

type Node = HashAggNode

type ExecutorBuilder = HashAggExecutorBuilder

impl StreamNodeBody for HashJoinVariant

type Node = HashJoinNode

type ExecutorBuilder = HashJoinExecutorBuilder

impl StreamNodeBody for HopWindowVariant

type Node = HopWindowNode

type ExecutorBuilder = HopWindowExecutorBuilder

impl StreamNodeBody for IcebergWithPkIndexDvMergerVariant

type Node = IcebergWithPkIndexDvMergerNode

type ExecutorBuilder = IcebergWithPkIndexDvMergerExecutorBuilder

impl StreamNodeBody for IcebergWithPkIndexWriterVariant

type Node = IcebergWithPkIndexWriterNode

type ExecutorBuilder = IcebergWithPkIndexWriterExecutorBuilder

impl StreamNodeBody for LocalApproxPercentileVariant

type Node = LocalApproxPercentileNode

type ExecutorBuilder = LocalApproxPercentileExecutorBuilder

impl StreamNodeBody for LocalityProviderVariant

type Node = LocalityProviderNode

type ExecutorBuilder = LocalityProviderBuilder

impl StreamNodeBody for LookupUnionVariant

type Node = LookupUnionNode

type ExecutorBuilder = LookupUnionExecutorBuilder

impl StreamNodeBody for LookupVariant

type Node = LookupNode

type ExecutorBuilder = LookupExecutorBuilder

impl StreamNodeBody for MaterializeVariant

type Node = MaterializeNode

type ExecutorBuilder = MaterializeExecutorBuilder

impl StreamNodeBody for MaterializedExprsVariant

type Node = MaterializedExprsNode

type ExecutorBuilder = MaterializedExprsExecutorBuilder

impl StreamNodeBody for MergeVariant

type Node = MergeNode

type ExecutorBuilder = MergeExecutorBuilder

impl StreamNodeBody for NoOpVariant

type Node = NoOpNode

type ExecutorBuilder = NoOpExecutorBuilder

impl StreamNodeBody for NowVariant

type Node = NowNode

type ExecutorBuilder = NowExecutorBuilder

impl StreamNodeBody for OverWindowVariant

type Node = OverWindowNode

type ExecutorBuilder = OverWindowExecutorBuilder

impl StreamNodeBody for ProjectSetVariant

type Node = ProjectSetNode

type ExecutorBuilder = ProjectSetExecutorBuilder

impl StreamNodeBody for ProjectVariant

type Node = ProjectNode

type ExecutorBuilder = ProjectExecutorBuilder

impl StreamNodeBody for RowIdGenVariant

type Node = RowIdGenNode

type ExecutorBuilder = RowIdGenExecutorBuilder

impl StreamNodeBody for RowMergeVariant

type Node = RowMergeNode

type ExecutorBuilder = RowMergeExecutorBuilder

impl StreamNodeBody for SimpleAggVariant

type Node = SimpleAggNode

type ExecutorBuilder = SimpleAggExecutorBuilder

impl StreamNodeBody for SinkVariant

type Node = SinkNode

type ExecutorBuilder = SinkExecutorBuilder

impl StreamNodeBody for SortVariant

type Node = SortNode

type ExecutorBuilder = SortExecutorBuilder

impl StreamNodeBody for SourceBackfillVariant

type Node = SourceBackfillNode

type ExecutorBuilder = SourceBackfillExecutorBuilder

impl StreamNodeBody for SourceVariant

type Node = SourceNode

type ExecutorBuilder = SourceExecutorBuilder

impl StreamNodeBody for StatelessSimpleAggVariant

type Node = SimpleAggNode

type ExecutorBuilder = StatelessSimpleAggExecutorBuilder

impl StreamNodeBody for StreamCdcScanVariant

type Node = StreamCdcScanNode

type ExecutorBuilder = StreamCdcScanExecutorBuilder

impl StreamNodeBody for StreamFsFetchVariant

type Node = StreamFsFetchNode

type ExecutorBuilder = FsFetchExecutorBuilder

impl StreamNodeBody for StreamScanVariant

type Node = StreamScanNode

type ExecutorBuilder = StreamScanExecutorBuilder

impl StreamNodeBody for SyncLogStoreVariant

type Node = SyncLogStoreNode

type ExecutorBuilder = SyncLogStoreExecutorBuilder

impl StreamNodeBody for TemporalJoinVariant

type Node = TemporalJoinNode

type ExecutorBuilder = TemporalJoinExecutorBuilder

impl StreamNodeBody for TopNVariant

type Node = TopNNode

type ExecutorBuilder = TopNExecutorBuilder<false>

impl StreamNodeBody for UnionVariant

type Node = UnionNode

type ExecutorBuilder = UnionExecutorBuilder

impl StreamNodeBody for UpstreamSinkUnionVariant

type Node = UpstreamSinkUnionNode

type ExecutorBuilder = UpstreamSinkUnionExecutorBuilder

impl StreamNodeBody for ValuesVariant

type Node = ValuesNode

type ExecutorBuilder = ValuesExecutorBuilder

impl StreamNodeBody for VectorIndexLookupJoinVariant

type Node = VectorIndexLookupJoinNode

type ExecutorBuilder = VectorIndexLookupJoinBuilder

impl StreamNodeBody for VectorIndexWriteVariant

type Node = VectorIndexWriteNode

type ExecutorBuilder = VectorIndexWriteExecutorBuilder

impl StreamNodeBody for WatermarkFilterVariant

type Node = WatermarkFilterNode

type ExecutorBuilder = WatermarkFilterBuilder

Implementors