pub struct Stream;
Expand description
The marker for stream convention.
Trait Implementations§
Source§impl ConventionMarker for Stream
impl ConventionMarker for Stream
Source§type Extra = StreamExtra
type Extra = StreamExtra
The extra fields in the
PlanBase
of this convention.type PlanNodeType = StreamPlanNodeType
type PlanRefDyn = dyn StreamPlanNode
Source§impl ExprRewritable<Stream> for StreamAsOfJoin
impl ExprRewritable<Stream> for StreamAsOfJoin
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamCdcTableScan
impl ExprRewritable<Stream> for StreamCdcTableScan
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamChangeLog
impl ExprRewritable<Stream> for StreamChangeLog
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamDedup
impl ExprRewritable<Stream> for StreamDedup
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamDeltaJoin
impl ExprRewritable<Stream> for StreamDeltaJoin
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamDml
impl ExprRewritable<Stream> for StreamDml
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamDynamicFilter
impl ExprRewritable<Stream> for StreamDynamicFilter
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamEowcOverWindow
impl ExprRewritable<Stream> for StreamEowcOverWindow
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamEowcSort
impl ExprRewritable<Stream> for StreamEowcSort
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamExchange
impl ExprRewritable<Stream> for StreamExchange
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamExpand
impl ExprRewritable<Stream> for StreamExpand
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamFilter
impl ExprRewritable<Stream> for StreamFilter
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamFsFetch
impl ExprRewritable<Stream> for StreamFsFetch
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamGlobalApproxPercentile
impl ExprRewritable<Stream> for StreamGlobalApproxPercentile
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _rewriter: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamGroupTopN
impl ExprRewritable<Stream> for StreamGroupTopN
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamHashAgg
impl ExprRewritable<Stream> for StreamHashAgg
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamHashJoin
impl ExprRewritable<Stream> for StreamHashJoin
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamHopWindow
impl ExprRewritable<Stream> for StreamHopWindow
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamLocalApproxPercentile
impl ExprRewritable<Stream> for StreamLocalApproxPercentile
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _rewriter: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamMaterialize
impl ExprRewritable<Stream> for StreamMaterialize
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamMaterializedExprs
impl ExprRewritable<Stream> for StreamMaterializedExprs
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamNow
impl ExprRewritable<Stream> for StreamNow
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamOverWindow
impl ExprRewritable<Stream> for StreamOverWindow
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamProject
impl ExprRewritable<Stream> for StreamProject
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamProjectSet
impl ExprRewritable<Stream> for StreamProjectSet
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamRowIdGen
impl ExprRewritable<Stream> for StreamRowIdGen
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamRowMerge
impl ExprRewritable<Stream> for StreamRowMerge
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _rewriter: &mut dyn ExprRewriter) -> PlanRef
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamSimpleAgg
impl ExprRewritable<Stream> for StreamSimpleAgg
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamSink
impl ExprRewritable<Stream> for StreamSink
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamSource
impl ExprRewritable<Stream> for StreamSource
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamSourceScan
impl ExprRewritable<Stream> for StreamSourceScan
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamStatelessSimpleAgg
impl ExprRewritable<Stream> for StreamStatelessSimpleAgg
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamSyncLogStore
impl ExprRewritable<Stream> for StreamSyncLogStore
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamTableScan
impl ExprRewritable<Stream> for StreamTableScan
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamTemporalJoin
impl ExprRewritable<Stream> for StreamTemporalJoin
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamTopN
impl ExprRewritable<Stream> for StreamTopN
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamUnion
impl ExprRewritable<Stream> for StreamUnion
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Stream> for StreamValues
impl ExprRewritable<Stream> for StreamValues
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Stream> for StreamWatermarkFilter
impl ExprRewritable<Stream> for StreamWatermarkFilter
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl InfallibleRule<Stream> for AddLogstoreRule
impl InfallibleRule<Stream> for AddLogstoreRule
Source§impl InfallibleRule<Stream> for IndexDeltaJoinRule
impl InfallibleRule<Stream> for IndexDeltaJoinRule
Source§impl PlanTreeNode<Stream> for StreamAsOfJoin
impl PlanTreeNode<Stream> for StreamAsOfJoin
Source§impl PlanTreeNode<Stream> for StreamCdcTableScan
impl PlanTreeNode<Stream> for StreamCdcTableScan
Source§impl PlanTreeNode<Stream> for StreamChangeLog
impl PlanTreeNode<Stream> for StreamChangeLog
Source§impl PlanTreeNode<Stream> for StreamDedup
impl PlanTreeNode<Stream> for StreamDedup
Source§impl PlanTreeNode<Stream> for StreamDeltaJoin
impl PlanTreeNode<Stream> for StreamDeltaJoin
Source§impl PlanTreeNode<Stream> for StreamDml
impl PlanTreeNode<Stream> for StreamDml
Source§impl PlanTreeNode<Stream> for StreamDynamicFilter
impl PlanTreeNode<Stream> for StreamDynamicFilter
Source§impl PlanTreeNode<Stream> for StreamEowcOverWindow
impl PlanTreeNode<Stream> for StreamEowcOverWindow
Source§impl PlanTreeNode<Stream> for StreamEowcSort
impl PlanTreeNode<Stream> for StreamEowcSort
Source§impl PlanTreeNode<Stream> for StreamExchange
impl PlanTreeNode<Stream> for StreamExchange
Source§impl PlanTreeNode<Stream> for StreamExpand
impl PlanTreeNode<Stream> for StreamExpand
Source§impl PlanTreeNode<Stream> for StreamFilter
impl PlanTreeNode<Stream> for StreamFilter
Source§impl PlanTreeNode<Stream> for StreamFsFetch
impl PlanTreeNode<Stream> for StreamFsFetch
Source§impl PlanTreeNode<Stream> for StreamGroupTopN
impl PlanTreeNode<Stream> for StreamGroupTopN
Source§impl PlanTreeNode<Stream> for StreamHashAgg
impl PlanTreeNode<Stream> for StreamHashAgg
Source§impl PlanTreeNode<Stream> for StreamHashJoin
impl PlanTreeNode<Stream> for StreamHashJoin
Source§impl PlanTreeNode<Stream> for StreamHopWindow
impl PlanTreeNode<Stream> for StreamHopWindow
Source§impl PlanTreeNode<Stream> for StreamMaterialize
impl PlanTreeNode<Stream> for StreamMaterialize
Source§impl PlanTreeNode<Stream> for StreamMaterializedExprs
impl PlanTreeNode<Stream> for StreamMaterializedExprs
Source§impl PlanTreeNode<Stream> for StreamNow
impl PlanTreeNode<Stream> for StreamNow
Source§impl PlanTreeNode<Stream> for StreamOverWindow
impl PlanTreeNode<Stream> for StreamOverWindow
Source§impl PlanTreeNode<Stream> for StreamProject
impl PlanTreeNode<Stream> for StreamProject
Source§impl PlanTreeNode<Stream> for StreamProjectSet
impl PlanTreeNode<Stream> for StreamProjectSet
Source§impl PlanTreeNode<Stream> for StreamRowIdGen
impl PlanTreeNode<Stream> for StreamRowIdGen
Source§impl PlanTreeNode<Stream> for StreamRowMerge
impl PlanTreeNode<Stream> for StreamRowMerge
Source§impl PlanTreeNode<Stream> for StreamSimpleAgg
impl PlanTreeNode<Stream> for StreamSimpleAgg
Source§impl PlanTreeNode<Stream> for StreamSink
impl PlanTreeNode<Stream> for StreamSink
Source§impl PlanTreeNode<Stream> for StreamSource
impl PlanTreeNode<Stream> for StreamSource
Source§impl PlanTreeNode<Stream> for StreamSourceScan
impl PlanTreeNode<Stream> for StreamSourceScan
Source§impl PlanTreeNode<Stream> for StreamSyncLogStore
impl PlanTreeNode<Stream> for StreamSyncLogStore
Source§impl PlanTreeNode<Stream> for StreamTableScan
impl PlanTreeNode<Stream> for StreamTableScan
Source§impl PlanTreeNode<Stream> for StreamTemporalJoin
impl PlanTreeNode<Stream> for StreamTemporalJoin
Source§impl PlanTreeNode<Stream> for StreamTopN
impl PlanTreeNode<Stream> for StreamTopN
Source§impl PlanTreeNode<Stream> for StreamUnion
impl PlanTreeNode<Stream> for StreamUnion
Source§impl PlanTreeNode<Stream> for StreamValues
impl PlanTreeNode<Stream> for StreamValues
Source§impl PlanTreeNode<Stream> for StreamWatermarkFilter
impl PlanTreeNode<Stream> for StreamWatermarkFilter
Source§impl PlanTreeNodeBinary<Stream> for StreamAsOfJoin
impl PlanTreeNodeBinary<Stream> for StreamAsOfJoin
fn left(&self) -> PlanRef
fn right(&self) -> PlanRef
fn clone_with_left_right(&self, left: PlanRef, right: PlanRef) -> Self
Source§fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input nodes during rewriting. Read more
Source§impl PlanTreeNodeBinary<Stream> for StreamDeltaJoin
impl PlanTreeNodeBinary<Stream> for StreamDeltaJoin
fn left(&self) -> PlanRef
fn right(&self) -> PlanRef
fn clone_with_left_right(&self, left: PlanRef, right: PlanRef) -> Self
Source§fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input nodes during rewriting. Read more
Source§impl PlanTreeNodeBinary<Stream> for StreamDynamicFilter
impl PlanTreeNodeBinary<Stream> for StreamDynamicFilter
fn left(&self) -> PlanRef
fn right(&self) -> PlanRef
fn clone_with_left_right(&self, left: PlanRef, right: PlanRef) -> Self
Source§fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input nodes during rewriting. Read more
Source§impl PlanTreeNodeBinary<Stream> for StreamHashJoin
impl PlanTreeNodeBinary<Stream> for StreamHashJoin
fn left(&self) -> PlanRef
fn right(&self) -> PlanRef
fn clone_with_left_right(&self, left: PlanRef, right: PlanRef) -> Self
Source§fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input nodes during rewriting. Read more
Source§impl PlanTreeNodeBinary<Stream> for StreamRowMerge
impl PlanTreeNodeBinary<Stream> for StreamRowMerge
fn left(&self) -> PlanRef
fn right(&self) -> PlanRef
fn clone_with_left_right(&self, left: PlanRef, right: PlanRef) -> Self
Source§fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input nodes during rewriting. Read more
Source§impl PlanTreeNodeBinary<Stream> for StreamTemporalJoin
impl PlanTreeNodeBinary<Stream> for StreamTemporalJoin
fn left(&self) -> PlanRef
fn right(&self) -> PlanRef
fn clone_with_left_right(&self, left: PlanRef, right: PlanRef) -> Self
Source§fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_left_right(
&self,
_left: PlanRef<C>,
_left_col_change: ColIndexMapping,
_right: PlanRef<C>,
_right_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input nodes during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamChangeLog
impl PlanTreeNodeUnary<Stream> for StreamChangeLog
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamDedup
impl PlanTreeNodeUnary<Stream> for StreamDedup
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamDml
impl PlanTreeNodeUnary<Stream> for StreamDml
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamEowcOverWindow
impl PlanTreeNodeUnary<Stream> for StreamEowcOverWindow
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamEowcSort
impl PlanTreeNodeUnary<Stream> for StreamEowcSort
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamExchange
impl PlanTreeNodeUnary<Stream> for StreamExchange
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamExpand
impl PlanTreeNodeUnary<Stream> for StreamExpand
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamFilter
impl PlanTreeNodeUnary<Stream> for StreamFilter
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamFsFetch
impl PlanTreeNodeUnary<Stream> for StreamFsFetch
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamGlobalApproxPercentile
impl PlanTreeNodeUnary<Stream> for StreamGlobalApproxPercentile
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamGroupTopN
impl PlanTreeNodeUnary<Stream> for StreamGroupTopN
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamHashAgg
impl PlanTreeNodeUnary<Stream> for StreamHashAgg
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamHopWindow
impl PlanTreeNodeUnary<Stream> for StreamHopWindow
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamLocalApproxPercentile
impl PlanTreeNodeUnary<Stream> for StreamLocalApproxPercentile
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamMaterialize
impl PlanTreeNodeUnary<Stream> for StreamMaterialize
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamMaterializedExprs
impl PlanTreeNodeUnary<Stream> for StreamMaterializedExprs
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamOverWindow
impl PlanTreeNodeUnary<Stream> for StreamOverWindow
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamProject
impl PlanTreeNodeUnary<Stream> for StreamProject
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamProjectSet
impl PlanTreeNodeUnary<Stream> for StreamProjectSet
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamRowIdGen
impl PlanTreeNodeUnary<Stream> for StreamRowIdGen
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
fn input(&self) -> PlanRef
fn clone_with_input(&self, _input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamSimpleAgg
impl PlanTreeNodeUnary<Stream> for StreamSimpleAgg
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamSink
impl PlanTreeNodeUnary<Stream> for StreamSink
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamStatelessSimpleAgg
impl PlanTreeNodeUnary<Stream> for StreamStatelessSimpleAgg
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamSyncLogStore
impl PlanTreeNodeUnary<Stream> for StreamSyncLogStore
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamTopN
impl PlanTreeNodeUnary<Stream> for StreamTopN
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
Source§impl PlanTreeNodeUnary<Stream> for StreamWatermarkFilter
impl PlanTreeNodeUnary<Stream> for StreamWatermarkFilter
fn input(&self) -> PlanRef
fn clone_with_input(&self, input: PlanRef) -> Self
Source§fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
fn rewrite_with_input(
&self,
_input: PlanRef<C>,
_input_col_change: ColIndexMapping,
) -> (Self, ColIndexMapping)where
Self: Sized,
Rewrites the plan node according to the schema change of its input node during rewriting. Read more
fn replace_input(&self, plan: PlanRef)
impl Eq for Stream
impl StructuralPartialEq for Stream
Auto Trait Implementations§
impl Freeze for Stream
impl RefUnwindSafe for Stream
impl Send for Stream
impl Sync for Stream
impl Unpin for Stream
impl UnwindSafe for Stream
Blanket Implementations§
§impl<T> AsAny for T
impl<T> AsAny for T
§fn any_ref(&self) -> &(dyn Any + Send + Sync + 'static)
fn any_ref(&self) -> &(dyn Any + Send + Sync + 'static)
Obtains a
dyn Any
reference to the object: Read more§fn as_any(self: Arc<T>) -> Arc<dyn Any + Send + Sync>
fn as_any(self: Arc<T>) -> Arc<dyn Any + Send + Sync>
Obtains an
Arc<dyn Any>
reference to the object: Read more§fn into_any(self: Box<T>) -> Box<dyn Any + Send + Sync>
fn into_any(self: Box<T>) -> Box<dyn Any + Send + Sync>
Converts the object to
Box<dyn Any>
: Read more§fn type_name(&self) -> &'static str
fn type_name(&self) -> &'static str
Convenient wrapper for
std::any::type_name
, since Any
does not provide it and
Any::type_id
is useless as a debugging aid (its Debug
is just a mess of hex digits).Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Conv for T
impl<T> Conv for T
§impl<Choices> CoproductSubsetter<CNil, HNil> for Choices
impl<Choices> CoproductSubsetter<CNil, HNil> for Choices
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Converts
Box<dyn Trait>
(where Trait: Downcast
) to Box<dyn Any>
, which can then be
downcast
into Box<dyn ConcreteType>
where ConcreteType
implements Trait
.§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Converts
Rc<Trait>
(where Trait: Downcast
) to Rc<Any>
, which can then be further
downcast
into Rc<ConcreteType>
where ConcreteType
implements Trait
.§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Converts
&Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &Any
’s vtable from &Trait
’s.§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Converts
&mut Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &mut Any
’s vtable from &mut Trait
’s.§impl<T> DowncastSend for T
impl<T> DowncastSend for T
§impl<T> DowncastSync for T
impl<T> DowncastSync for T
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
Causes
self
to use its Binary
implementation when Debug
-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
Causes
self
to use its Display
implementation when
Debug
-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
Causes
self
to use its LowerExp
implementation when
Debug
-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
Causes
self
to use its LowerHex
implementation when
Debug
-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
Causes
self
to use its Octal
implementation when Debug
-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
Causes
self
to use its Pointer
implementation when
Debug
-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
Causes
self
to use its UpperExp
implementation when
Debug
-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
Causes
self
to use its UpperHex
implementation when
Debug
-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
Formats each item in a sequence. Read more
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
§impl<T> IntoResult<T> for T
impl<T> IntoResult<T> for T
type Err = Infallible
fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>
Creates a shared type from an unshared type.
§impl<T, U, I> LiftInto<U, I> for Twhere
U: LiftFrom<T, I>,
impl<T, U, I> LiftInto<U, I> for Twhere
U: LiftFrom<T, I>,
Source§impl<M> MetricVecRelabelExt for M
impl<M> MetricVecRelabelExt for M
Source§fn relabel(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level
.Source§fn relabel_n(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
relabel_num: usize,
) -> RelabeledMetricVec<M>
fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level_relabel_n
.Source§fn relabel_debug_1(
self,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level_relabel_n
with metric_level
set to
MetricLevel::Debug
and relabel_num
set to 1.§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Pipes by value. This is generally the method you want to use. Read more
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
Borrows
self
and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
Mutably borrows
self
and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
Borrows
self
, then passes self.as_ref()
into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
Mutably borrows
self
, then passes self.as_mut()
into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
Borrows
self
, then passes self.deref()
into the pipe function.Source§impl<V> PlanVisitor<Stream> for Vwhere
V: StreamPlanVisitor,
impl<V> PlanVisitor<Stream> for Vwhere
V: StreamPlanVisitor,
§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> SameOrElseExt for Twhere
T: Eq,
impl<T> SameOrElseExt for Twhere
T: Eq,
Source§fn same_or_else(self, other: T, f: impl FnOnce() -> T) -> T
fn same_or_else(self, other: T, f: impl FnOnce() -> T) -> T
Check if
self
and other
are equal, if so, return self
, otherwise return the result of f()
.§impl<T> Scope for T
impl<T> Scope for T
§impl<Source> Sculptor<HNil, HNil> for Source
impl<Source> Sculptor<HNil, HNil> for Source
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Immutable access to the
Borrow<B>
of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
Mutable access to the
BorrowMut<B>
of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
Immutable access to the
AsRef<R>
view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
Mutable access to the
AsMut<R>
view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Immutable access to the
Deref::Target
of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Mutable access to the
Deref::Target
of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
Calls
.tap()
only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
Calls
.tap_mut()
only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
Calls
.tap_borrow()
only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
Calls
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
Calls
.tap_ref()
only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
Calls
.tap_ref_mut()
only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
Calls
.tap_deref()
only in debug builds, and is erased in release
builds.