Enum NodeBody

pub enum NodeBody {
    Source(SourceNode),
    Project(ProjectNode),
    Filter(FilterNode),
    Materialize(MaterializeNode),
    StatelessSimpleAgg(SimpleAggNode),
    SimpleAgg(SimpleAggNode),
    HashAgg(HashAggNode),
    AppendOnlyTopN(TopNNode),
    HashJoin(HashJoinNode),
    TopN(TopNNode),
    HopWindow(HopWindowNode),
    Merge(MergeNode),
    Exchange(ExchangeNode),
    StreamScan(StreamScanNode),
    BatchPlan(BatchPlanNode),
    Lookup(LookupNode),
    Arrange(ArrangeNode),
    LookupUnion(LookupUnionNode),
    Union(UnionNode),
    DeltaIndexJoin(DeltaIndexJoinNode),
    Sink(SinkNode),
    Expand(ExpandNode),
    DynamicFilter(DynamicFilterNode),
    ProjectSet(ProjectSetNode),
    GroupTopN(GroupTopNNode),
    Sort(SortNode),
    WatermarkFilter(WatermarkFilterNode),
    Dml(DmlNode),
    RowIdGen(RowIdGenNode),
    Now(NowNode),
    AppendOnlyGroupTopN(GroupTopNNode),
    TemporalJoin(TemporalJoinNode),
    BarrierRecv(BarrierRecvNode),
    Values(ValuesNode),
    AppendOnlyDedup(DedupNode),
    NoOp(NoOpNode),
    EowcOverWindow(EowcOverWindowNode),
    OverWindow(OverWindowNode),
    StreamFsFetch(StreamFsFetchNode),
    StreamCdcScan(StreamCdcScanNode),
    CdcFilter(CdcFilterNode),
    SourceBackfill(SourceBackfillNode),
    Changelog(ChangeLogNode),
    LocalApproxPercentile(LocalApproxPercentileNode),
    GlobalApproxPercentile(GlobalApproxPercentileNode),
    RowMerge(RowMergeNode),
    AsOfJoin(AsOfJoinNode),
}

Variants

Source(SourceNode)

Project(ProjectNode)

Filter(FilterNode)

Materialize(MaterializeNode)

StatelessSimpleAgg(SimpleAggNode)

SimpleAgg(SimpleAggNode)

HashAgg(HashAggNode)

AppendOnlyTopN(TopNNode)

HashJoin(HashJoinNode)

TopN(TopNNode)

HopWindow(HopWindowNode)

Merge(MergeNode)

Exchange(ExchangeNode)

StreamScan(StreamScanNode)

BatchPlan(BatchPlanNode)

Lookup(LookupNode)

Arrange(ArrangeNode)

LookupUnion(LookupUnionNode)

Union(UnionNode)

DeltaIndexJoin(DeltaIndexJoinNode)

Sink(SinkNode)

Expand(ExpandNode)

DynamicFilter(DynamicFilterNode)

ProjectSet(ProjectSetNode)

GroupTopN(GroupTopNNode)

Sort(SortNode)

WatermarkFilter(WatermarkFilterNode)

Dml(DmlNode)

RowIdGen(RowIdGenNode)

Now(NowNode)

AppendOnlyGroupTopN(GroupTopNNode)

TemporalJoin(TemporalJoinNode)

BarrierRecv(BarrierRecvNode)

Values(ValuesNode)

AppendOnlyDedup(DedupNode)

NoOp(NoOpNode)

EowcOverWindow(EowcOverWindowNode)

OverWindow(OverWindowNode)

StreamFsFetch(StreamFsFetchNode)

StreamCdcScan(StreamCdcScanNode)

CdcFilter(CdcFilterNode)

SourceBackfill(SourceBackfillNode)

Changelog(ChangeLogNode)

LocalApproxPercentile(LocalApproxPercentileNode)

GlobalApproxPercentile(GlobalApproxPercentileNode)

RowMerge(RowMergeNode)

AsOfJoin(AsOfJoinNode)

Implementations

impl NodeBody

pub fn encode(&self, buf: &mut impl BufMut)

Encodes the message to a buffer.

pub fn merge( field: &mut Option<NodeBody>, tag: u32, wire_type: WireType, buf: &mut impl Buf, ctx: DecodeContext, ) -> Result<(), DecodeError>

Decodes an instance of the message from a buffer, and merges it into self.

pub fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

impl NodeBody

pub fn is_source(&self) -> bool

Returns true if this is a NodeBody::Source, otherwise false

pub fn as_source_mut(&mut self) -> Option<&mut SourceNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Source, otherwise None

pub fn as_source(&self) -> Option<&SourceNode>

Optionally returns references to the inner fields if this is a NodeBody::Source, otherwise None

pub fn into_source(self) -> Result<SourceNode, Self>

Returns the inner fields if this is a NodeBody::Source, otherwise returns back the enum in the Err case of the result

pub fn is_project(&self) -> bool

Returns true if this is a NodeBody::Project, otherwise false

pub fn as_project_mut(&mut self) -> Option<&mut ProjectNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Project, otherwise None

pub fn as_project(&self) -> Option<&ProjectNode>

Optionally returns references to the inner fields if this is a NodeBody::Project, otherwise None

pub fn into_project(self) -> Result<ProjectNode, Self>

Returns the inner fields if this is a NodeBody::Project, otherwise returns back the enum in the Err case of the result

pub fn is_filter(&self) -> bool

Returns true if this is a NodeBody::Filter, otherwise false

pub fn as_filter_mut(&mut self) -> Option<&mut FilterNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Filter, otherwise None

pub fn as_filter(&self) -> Option<&FilterNode>

Optionally returns references to the inner fields if this is a NodeBody::Filter, otherwise None

pub fn into_filter(self) -> Result<FilterNode, Self>

Returns the inner fields if this is a NodeBody::Filter, otherwise returns back the enum in the Err case of the result

pub fn is_materialize(&self) -> bool

Returns true if this is a NodeBody::Materialize, otherwise false

pub fn as_materialize_mut(&mut self) -> Option<&mut MaterializeNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Materialize, otherwise None

pub fn as_materialize(&self) -> Option<&MaterializeNode>

Optionally returns references to the inner fields if this is a NodeBody::Materialize, otherwise None

pub fn into_materialize(self) -> Result<MaterializeNode, Self>

Returns the inner fields if this is a NodeBody::Materialize, otherwise returns back the enum in the Err case of the result

pub fn is_stateless_simple_agg(&self) -> bool

Returns true if this is a NodeBody::StatelessSimpleAgg, otherwise false

pub fn as_stateless_simple_agg_mut(&mut self) -> Option<&mut SimpleAggNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::StatelessSimpleAgg, otherwise None

pub fn as_stateless_simple_agg(&self) -> Option<&SimpleAggNode>

Optionally returns references to the inner fields if this is a NodeBody::StatelessSimpleAgg, otherwise None

pub fn into_stateless_simple_agg(self) -> Result<SimpleAggNode, Self>

Returns the inner fields if this is a NodeBody::StatelessSimpleAgg, otherwise returns back the enum in the Err case of the result

pub fn is_simple_agg(&self) -> bool

Returns true if this is a NodeBody::SimpleAgg, otherwise false

pub fn as_simple_agg_mut(&mut self) -> Option<&mut SimpleAggNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::SimpleAgg, otherwise None

pub fn as_simple_agg(&self) -> Option<&SimpleAggNode>

Optionally returns references to the inner fields if this is a NodeBody::SimpleAgg, otherwise None

pub fn into_simple_agg(self) -> Result<SimpleAggNode, Self>

Returns the inner fields if this is a NodeBody::SimpleAgg, otherwise returns back the enum in the Err case of the result

pub fn is_hash_agg(&self) -> bool

Returns true if this is a NodeBody::HashAgg, otherwise false

pub fn as_hash_agg_mut(&mut self) -> Option<&mut HashAggNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::HashAgg, otherwise None

pub fn as_hash_agg(&self) -> Option<&HashAggNode>

Optionally returns references to the inner fields if this is a NodeBody::HashAgg, otherwise None

pub fn into_hash_agg(self) -> Result<HashAggNode, Self>

Returns the inner fields if this is a NodeBody::HashAgg, otherwise returns back the enum in the Err case of the result

pub fn is_append_only_top_n(&self) -> bool

Returns true if this is a NodeBody::AppendOnlyTopN, otherwise false

pub fn as_append_only_top_n_mut(&mut self) -> Option<&mut TopNNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::AppendOnlyTopN, otherwise None

pub fn as_append_only_top_n(&self) -> Option<&TopNNode>

Optionally returns references to the inner fields if this is a NodeBody::AppendOnlyTopN, otherwise None

pub fn into_append_only_top_n(self) -> Result<TopNNode, Self>

Returns the inner fields if this is a NodeBody::AppendOnlyTopN, otherwise returns back the enum in the Err case of the result

pub fn is_hash_join(&self) -> bool

Returns true if this is a NodeBody::HashJoin, otherwise false

pub fn as_hash_join_mut(&mut self) -> Option<&mut HashJoinNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::HashJoin, otherwise None

pub fn as_hash_join(&self) -> Option<&HashJoinNode>

Optionally returns references to the inner fields if this is a NodeBody::HashJoin, otherwise None

pub fn into_hash_join(self) -> Result<HashJoinNode, Self>

Returns the inner fields if this is a NodeBody::HashJoin, otherwise returns back the enum in the Err case of the result

pub fn is_top_n(&self) -> bool

Returns true if this is a NodeBody::TopN, otherwise false

pub fn as_top_n_mut(&mut self) -> Option<&mut TopNNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::TopN, otherwise None

pub fn as_top_n(&self) -> Option<&TopNNode>

Optionally returns references to the inner fields if this is a NodeBody::TopN, otherwise None

pub fn into_top_n(self) -> Result<TopNNode, Self>

Returns the inner fields if this is a NodeBody::TopN, otherwise returns back the enum in the Err case of the result

pub fn is_hop_window(&self) -> bool

Returns true if this is a NodeBody::HopWindow, otherwise false

pub fn as_hop_window_mut(&mut self) -> Option<&mut HopWindowNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::HopWindow, otherwise None

pub fn as_hop_window(&self) -> Option<&HopWindowNode>

Optionally returns references to the inner fields if this is a NodeBody::HopWindow, otherwise None

pub fn into_hop_window(self) -> Result<HopWindowNode, Self>

Returns the inner fields if this is a NodeBody::HopWindow, otherwise returns back the enum in the Err case of the result

pub fn is_merge(&self) -> bool

Returns true if this is a NodeBody::Merge, otherwise false

pub fn as_merge_mut(&mut self) -> Option<&mut MergeNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Merge, otherwise None

pub fn as_merge(&self) -> Option<&MergeNode>

Optionally returns references to the inner fields if this is a NodeBody::Merge, otherwise None

pub fn into_merge(self) -> Result<MergeNode, Self>

Returns the inner fields if this is a NodeBody::Merge, otherwise returns back the enum in the Err case of the result

pub fn is_exchange(&self) -> bool

Returns true if this is a NodeBody::Exchange, otherwise false

pub fn as_exchange_mut(&mut self) -> Option<&mut ExchangeNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Exchange, otherwise None

pub fn as_exchange(&self) -> Option<&ExchangeNode>

Optionally returns references to the inner fields if this is a NodeBody::Exchange, otherwise None

pub fn into_exchange(self) -> Result<ExchangeNode, Self>

Returns the inner fields if this is a NodeBody::Exchange, otherwise returns back the enum in the Err case of the result

pub fn is_stream_scan(&self) -> bool

Returns true if this is a NodeBody::StreamScan, otherwise false

pub fn as_stream_scan_mut(&mut self) -> Option<&mut StreamScanNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::StreamScan, otherwise None

pub fn as_stream_scan(&self) -> Option<&StreamScanNode>

Optionally returns references to the inner fields if this is a NodeBody::StreamScan, otherwise None

pub fn into_stream_scan(self) -> Result<StreamScanNode, Self>

Returns the inner fields if this is a NodeBody::StreamScan, otherwise returns back the enum in the Err case of the result

pub fn is_batch_plan(&self) -> bool

Returns true if this is a NodeBody::BatchPlan, otherwise false

pub fn as_batch_plan_mut(&mut self) -> Option<&mut BatchPlanNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::BatchPlan, otherwise None

pub fn as_batch_plan(&self) -> Option<&BatchPlanNode>

Optionally returns references to the inner fields if this is a NodeBody::BatchPlan, otherwise None

pub fn into_batch_plan(self) -> Result<BatchPlanNode, Self>

Returns the inner fields if this is a NodeBody::BatchPlan, otherwise returns back the enum in the Err case of the result

pub fn is_lookup(&self) -> bool

Returns true if this is a NodeBody::Lookup, otherwise false

pub fn as_lookup_mut(&mut self) -> Option<&mut LookupNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Lookup, otherwise None

pub fn as_lookup(&self) -> Option<&LookupNode>

Optionally returns references to the inner fields if this is a NodeBody::Lookup, otherwise None

pub fn into_lookup(self) -> Result<LookupNode, Self>

Returns the inner fields if this is a NodeBody::Lookup, otherwise returns back the enum in the Err case of the result

pub fn is_arrange(&self) -> bool

Returns true if this is a NodeBody::Arrange, otherwise false

pub fn as_arrange_mut(&mut self) -> Option<&mut ArrangeNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Arrange, otherwise None

pub fn as_arrange(&self) -> Option<&ArrangeNode>

Optionally returns references to the inner fields if this is a NodeBody::Arrange, otherwise None

pub fn into_arrange(self) -> Result<ArrangeNode, Self>

Returns the inner fields if this is a NodeBody::Arrange, otherwise returns back the enum in the Err case of the result

pub fn is_lookup_union(&self) -> bool

Returns true if this is a NodeBody::LookupUnion, otherwise false

pub fn as_lookup_union_mut(&mut self) -> Option<&mut LookupUnionNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::LookupUnion, otherwise None

pub fn as_lookup_union(&self) -> Option<&LookupUnionNode>

Optionally returns references to the inner fields if this is a NodeBody::LookupUnion, otherwise None

pub fn into_lookup_union(self) -> Result<LookupUnionNode, Self>

Returns the inner fields if this is a NodeBody::LookupUnion, otherwise returns back the enum in the Err case of the result

pub fn is_union(&self) -> bool

Returns true if this is a NodeBody::Union, otherwise false

pub fn as_union_mut(&mut self) -> Option<&mut UnionNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Union, otherwise None

pub fn as_union(&self) -> Option<&UnionNode>

Optionally returns references to the inner fields if this is a NodeBody::Union, otherwise None

pub fn into_union(self) -> Result<UnionNode, Self>

Returns the inner fields if this is a NodeBody::Union, otherwise returns back the enum in the Err case of the result

pub fn is_delta_index_join(&self) -> bool

Returns true if this is a NodeBody::DeltaIndexJoin, otherwise false

pub fn as_delta_index_join_mut(&mut self) -> Option<&mut DeltaIndexJoinNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::DeltaIndexJoin, otherwise None

pub fn as_delta_index_join(&self) -> Option<&DeltaIndexJoinNode>

Optionally returns references to the inner fields if this is a NodeBody::DeltaIndexJoin, otherwise None

pub fn into_delta_index_join(self) -> Result<DeltaIndexJoinNode, Self>

Returns the inner fields if this is a NodeBody::DeltaIndexJoin, otherwise returns back the enum in the Err case of the result

pub fn is_sink(&self) -> bool

Returns true if this is a NodeBody::Sink, otherwise false

pub fn as_sink_mut(&mut self) -> Option<&mut SinkNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Sink, otherwise None

pub fn as_sink(&self) -> Option<&SinkNode>

Optionally returns references to the inner fields if this is a NodeBody::Sink, otherwise None

pub fn into_sink(self) -> Result<SinkNode, Self>

Returns the inner fields if this is a NodeBody::Sink, otherwise returns back the enum in the Err case of the result

pub fn is_expand(&self) -> bool

Returns true if this is a NodeBody::Expand, otherwise false

pub fn as_expand_mut(&mut self) -> Option<&mut ExpandNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Expand, otherwise None

pub fn as_expand(&self) -> Option<&ExpandNode>

Optionally returns references to the inner fields if this is a NodeBody::Expand, otherwise None

pub fn into_expand(self) -> Result<ExpandNode, Self>

Returns the inner fields if this is a NodeBody::Expand, otherwise returns back the enum in the Err case of the result

pub fn is_dynamic_filter(&self) -> bool

Returns true if this is a NodeBody::DynamicFilter, otherwise false

pub fn as_dynamic_filter_mut(&mut self) -> Option<&mut DynamicFilterNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::DynamicFilter, otherwise None

pub fn as_dynamic_filter(&self) -> Option<&DynamicFilterNode>

Optionally returns references to the inner fields if this is a NodeBody::DynamicFilter, otherwise None

pub fn into_dynamic_filter(self) -> Result<DynamicFilterNode, Self>

Returns the inner fields if this is a NodeBody::DynamicFilter, otherwise returns back the enum in the Err case of the result

pub fn is_project_set(&self) -> bool

Returns true if this is a NodeBody::ProjectSet, otherwise false

pub fn as_project_set_mut(&mut self) -> Option<&mut ProjectSetNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::ProjectSet, otherwise None

pub fn as_project_set(&self) -> Option<&ProjectSetNode>

Optionally returns references to the inner fields if this is a NodeBody::ProjectSet, otherwise None

pub fn into_project_set(self) -> Result<ProjectSetNode, Self>

Returns the inner fields if this is a NodeBody::ProjectSet, otherwise returns back the enum in the Err case of the result

pub fn is_group_top_n(&self) -> bool

Returns true if this is a NodeBody::GroupTopN, otherwise false

pub fn as_group_top_n_mut(&mut self) -> Option<&mut GroupTopNNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::GroupTopN, otherwise None

pub fn as_group_top_n(&self) -> Option<&GroupTopNNode>

Optionally returns references to the inner fields if this is a NodeBody::GroupTopN, otherwise None

pub fn into_group_top_n(self) -> Result<GroupTopNNode, Self>

Returns the inner fields if this is a NodeBody::GroupTopN, otherwise returns back the enum in the Err case of the result

pub fn is_sort(&self) -> bool

Returns true if this is a NodeBody::Sort, otherwise false

pub fn as_sort_mut(&mut self) -> Option<&mut SortNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Sort, otherwise None

pub fn as_sort(&self) -> Option<&SortNode>

Optionally returns references to the inner fields if this is a NodeBody::Sort, otherwise None

pub fn into_sort(self) -> Result<SortNode, Self>

Returns the inner fields if this is a NodeBody::Sort, otherwise returns back the enum in the Err case of the result

pub fn is_watermark_filter(&self) -> bool

Returns true if this is a NodeBody::WatermarkFilter, otherwise false

pub fn as_watermark_filter_mut(&mut self) -> Option<&mut WatermarkFilterNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::WatermarkFilter, otherwise None

pub fn as_watermark_filter(&self) -> Option<&WatermarkFilterNode>

Optionally returns references to the inner fields if this is a NodeBody::WatermarkFilter, otherwise None

pub fn into_watermark_filter(self) -> Result<WatermarkFilterNode, Self>

Returns the inner fields if this is a NodeBody::WatermarkFilter, otherwise returns back the enum in the Err case of the result

pub fn is_dml(&self) -> bool

Returns true if this is a NodeBody::Dml, otherwise false

pub fn as_dml_mut(&mut self) -> Option<&mut DmlNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Dml, otherwise None

pub fn as_dml(&self) -> Option<&DmlNode>

Optionally returns references to the inner fields if this is a NodeBody::Dml, otherwise None

pub fn into_dml(self) -> Result<DmlNode, Self>

Returns the inner fields if this is a NodeBody::Dml, otherwise returns back the enum in the Err case of the result

pub fn is_row_id_gen(&self) -> bool

Returns true if this is a NodeBody::RowIdGen, otherwise false

pub fn as_row_id_gen_mut(&mut self) -> Option<&mut RowIdGenNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::RowIdGen, otherwise None

pub fn as_row_id_gen(&self) -> Option<&RowIdGenNode>

Optionally returns references to the inner fields if this is a NodeBody::RowIdGen, otherwise None

pub fn into_row_id_gen(self) -> Result<RowIdGenNode, Self>

Returns the inner fields if this is a NodeBody::RowIdGen, otherwise returns back the enum in the Err case of the result

pub fn is_now(&self) -> bool

Returns true if this is a NodeBody::Now, otherwise false

pub fn as_now_mut(&mut self) -> Option<&mut NowNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Now, otherwise None

pub fn as_now(&self) -> Option<&NowNode>

Optionally returns references to the inner fields if this is a NodeBody::Now, otherwise None

pub fn into_now(self) -> Result<NowNode, Self>

Returns the inner fields if this is a NodeBody::Now, otherwise returns back the enum in the Err case of the result

pub fn is_append_only_group_top_n(&self) -> bool

Returns true if this is a NodeBody::AppendOnlyGroupTopN, otherwise false

pub fn as_append_only_group_top_n_mut(&mut self) -> Option<&mut GroupTopNNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::AppendOnlyGroupTopN, otherwise None

pub fn as_append_only_group_top_n(&self) -> Option<&GroupTopNNode>

Optionally returns references to the inner fields if this is a NodeBody::AppendOnlyGroupTopN, otherwise None

pub fn into_append_only_group_top_n(self) -> Result<GroupTopNNode, Self>

Returns the inner fields if this is a NodeBody::AppendOnlyGroupTopN, otherwise returns back the enum in the Err case of the result

pub fn is_temporal_join(&self) -> bool

Returns true if this is a NodeBody::TemporalJoin, otherwise false

pub fn as_temporal_join_mut(&mut self) -> Option<&mut TemporalJoinNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::TemporalJoin, otherwise None

pub fn as_temporal_join(&self) -> Option<&TemporalJoinNode>

Optionally returns references to the inner fields if this is a NodeBody::TemporalJoin, otherwise None

pub fn into_temporal_join(self) -> Result<TemporalJoinNode, Self>

Returns the inner fields if this is a NodeBody::TemporalJoin, otherwise returns back the enum in the Err case of the result

pub fn is_barrier_recv(&self) -> bool

Returns true if this is a NodeBody::BarrierRecv, otherwise false

pub fn as_barrier_recv_mut(&mut self) -> Option<&mut BarrierRecvNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::BarrierRecv, otherwise None

pub fn as_barrier_recv(&self) -> Option<&BarrierRecvNode>

Optionally returns references to the inner fields if this is a NodeBody::BarrierRecv, otherwise None

pub fn into_barrier_recv(self) -> Result<BarrierRecvNode, Self>

Returns the inner fields if this is a NodeBody::BarrierRecv, otherwise returns back the enum in the Err case of the result

pub fn is_values(&self) -> bool

Returns true if this is a NodeBody::Values, otherwise false

pub fn as_values_mut(&mut self) -> Option<&mut ValuesNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Values, otherwise None

pub fn as_values(&self) -> Option<&ValuesNode>

Optionally returns references to the inner fields if this is a NodeBody::Values, otherwise None

pub fn into_values(self) -> Result<ValuesNode, Self>

Returns the inner fields if this is a NodeBody::Values, otherwise returns back the enum in the Err case of the result

pub fn is_append_only_dedup(&self) -> bool

Returns true if this is a NodeBody::AppendOnlyDedup, otherwise false

pub fn as_append_only_dedup_mut(&mut self) -> Option<&mut DedupNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::AppendOnlyDedup, otherwise None

pub fn as_append_only_dedup(&self) -> Option<&DedupNode>

Optionally returns references to the inner fields if this is a NodeBody::AppendOnlyDedup, otherwise None

pub fn into_append_only_dedup(self) -> Result<DedupNode, Self>

Returns the inner fields if this is a NodeBody::AppendOnlyDedup, otherwise returns back the enum in the Err case of the result

pub fn is_no_op(&self) -> bool

Returns true if this is a NodeBody::NoOp, otherwise false

pub fn as_no_op_mut(&mut self) -> Option<&mut NoOpNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::NoOp, otherwise None

pub fn as_no_op(&self) -> Option<&NoOpNode>

Optionally returns references to the inner fields if this is a NodeBody::NoOp, otherwise None

pub fn into_no_op(self) -> Result<NoOpNode, Self>

Returns the inner fields if this is a NodeBody::NoOp, otherwise returns back the enum in the Err case of the result

pub fn is_eowc_over_window(&self) -> bool

Returns true if this is a NodeBody::EowcOverWindow, otherwise false

pub fn as_eowc_over_window_mut(&mut self) -> Option<&mut EowcOverWindowNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::EowcOverWindow, otherwise None

pub fn as_eowc_over_window(&self) -> Option<&EowcOverWindowNode>

Optionally returns references to the inner fields if this is a NodeBody::EowcOverWindow, otherwise None

pub fn into_eowc_over_window(self) -> Result<EowcOverWindowNode, Self>

Returns the inner fields if this is a NodeBody::EowcOverWindow, otherwise returns back the enum in the Err case of the result

pub fn is_over_window(&self) -> bool

Returns true if this is a NodeBody::OverWindow, otherwise false

pub fn as_over_window_mut(&mut self) -> Option<&mut OverWindowNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::OverWindow, otherwise None

pub fn as_over_window(&self) -> Option<&OverWindowNode>

Optionally returns references to the inner fields if this is a NodeBody::OverWindow, otherwise None

pub fn into_over_window(self) -> Result<OverWindowNode, Self>

Returns the inner fields if this is a NodeBody::OverWindow, otherwise returns back the enum in the Err case of the result

pub fn is_stream_fs_fetch(&self) -> bool

Returns true if this is a NodeBody::StreamFsFetch, otherwise false

pub fn as_stream_fs_fetch_mut(&mut self) -> Option<&mut StreamFsFetchNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::StreamFsFetch, otherwise None

pub fn as_stream_fs_fetch(&self) -> Option<&StreamFsFetchNode>

Optionally returns references to the inner fields if this is a NodeBody::StreamFsFetch, otherwise None

pub fn into_stream_fs_fetch(self) -> Result<StreamFsFetchNode, Self>

Returns the inner fields if this is a NodeBody::StreamFsFetch, otherwise returns back the enum in the Err case of the result

pub fn is_stream_cdc_scan(&self) -> bool

Returns true if this is a NodeBody::StreamCdcScan, otherwise false

pub fn as_stream_cdc_scan_mut(&mut self) -> Option<&mut StreamCdcScanNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::StreamCdcScan, otherwise None

pub fn as_stream_cdc_scan(&self) -> Option<&StreamCdcScanNode>

Optionally returns references to the inner fields if this is a NodeBody::StreamCdcScan, otherwise None

pub fn into_stream_cdc_scan(self) -> Result<StreamCdcScanNode, Self>

Returns the inner fields if this is a NodeBody::StreamCdcScan, otherwise returns back the enum in the Err case of the result

pub fn is_cdc_filter(&self) -> bool

Returns true if this is a NodeBody::CdcFilter, otherwise false

pub fn as_cdc_filter_mut(&mut self) -> Option<&mut CdcFilterNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::CdcFilter, otherwise None

pub fn as_cdc_filter(&self) -> Option<&CdcFilterNode>

Optionally returns references to the inner fields if this is a NodeBody::CdcFilter, otherwise None

pub fn into_cdc_filter(self) -> Result<CdcFilterNode, Self>

Returns the inner fields if this is a NodeBody::CdcFilter, otherwise returns back the enum in the Err case of the result

pub fn is_source_backfill(&self) -> bool

Returns true if this is a NodeBody::SourceBackfill, otherwise false

pub fn as_source_backfill_mut(&mut self) -> Option<&mut SourceBackfillNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::SourceBackfill, otherwise None

pub fn as_source_backfill(&self) -> Option<&SourceBackfillNode>

Optionally returns references to the inner fields if this is a NodeBody::SourceBackfill, otherwise None

pub fn into_source_backfill(self) -> Result<SourceBackfillNode, Self>

Returns the inner fields if this is a NodeBody::SourceBackfill, otherwise returns back the enum in the Err case of the result

pub fn is_changelog(&self) -> bool

Returns true if this is a NodeBody::Changelog, otherwise false

pub fn as_changelog_mut(&mut self) -> Option<&mut ChangeLogNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Changelog, otherwise None

pub fn as_changelog(&self) -> Option<&ChangeLogNode>

Optionally returns references to the inner fields if this is a NodeBody::Changelog, otherwise None

pub fn into_changelog(self) -> Result<ChangeLogNode, Self>

Returns the inner fields if this is a NodeBody::Changelog, otherwise returns back the enum in the Err case of the result

pub fn is_local_approx_percentile(&self) -> bool

Returns true if this is a NodeBody::LocalApproxPercentile, otherwise false

pub fn as_local_approx_percentile_mut( &mut self, ) -> Option<&mut LocalApproxPercentileNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::LocalApproxPercentile, otherwise None

pub fn as_local_approx_percentile(&self) -> Option<&LocalApproxPercentileNode>

Optionally returns references to the inner fields if this is a NodeBody::LocalApproxPercentile, otherwise None

pub fn into_local_approx_percentile( self, ) -> Result<LocalApproxPercentileNode, Self>

Returns the inner fields if this is a NodeBody::LocalApproxPercentile, otherwise returns back the enum in the Err case of the result

pub fn is_global_approx_percentile(&self) -> bool

Returns true if this is a NodeBody::GlobalApproxPercentile, otherwise false

pub fn as_global_approx_percentile_mut( &mut self, ) -> Option<&mut GlobalApproxPercentileNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::GlobalApproxPercentile, otherwise None

pub fn as_global_approx_percentile(&self) -> Option<&GlobalApproxPercentileNode>

Optionally returns references to the inner fields if this is a NodeBody::GlobalApproxPercentile, otherwise None

pub fn into_global_approx_percentile( self, ) -> Result<GlobalApproxPercentileNode, Self>

Returns the inner fields if this is a NodeBody::GlobalApproxPercentile, otherwise returns back the enum in the Err case of the result

pub fn is_row_merge(&self) -> bool

Returns true if this is a NodeBody::RowMerge, otherwise false

pub fn as_row_merge_mut(&mut self) -> Option<&mut RowMergeNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::RowMerge, otherwise None

pub fn as_row_merge(&self) -> Option<&RowMergeNode>

Optionally returns references to the inner fields if this is a NodeBody::RowMerge, otherwise None

pub fn into_row_merge(self) -> Result<RowMergeNode, Self>

Returns the inner fields if this is a NodeBody::RowMerge, otherwise returns back the enum in the Err case of the result

pub fn is_as_of_join(&self) -> bool

Returns true if this is a NodeBody::AsOfJoin, otherwise false

pub fn as_as_of_join_mut(&mut self) -> Option<&mut AsOfJoinNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::AsOfJoin, otherwise None

pub fn as_as_of_join(&self) -> Option<&AsOfJoinNode>

Optionally returns references to the inner fields if this is a NodeBody::AsOfJoin, otherwise None

pub fn into_as_of_join(self) -> Result<AsOfJoinNode, Self>

Returns the inner fields if this is a NodeBody::AsOfJoin, otherwise returns back the enum in the Err case of the result

Trait Implementations

impl Clone for NodeBody

fn clone(&self) -> NodeBody

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NodeBody

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for NodeBody

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl PartialEq for NodeBody

fn eq(&self, other: &NodeBody) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for NodeBody