pub struct Batch;
Expand description
The marker for batch convention.
Trait Implementations§
Source§impl ConventionMarker for Batch
impl ConventionMarker for Batch
Source§type Extra = BatchExtra
type Extra = BatchExtra
The extra fields in the
PlanBase
of this convention.type PlanNodeType = BatchPlanNodeType
type PlanRefDyn = dyn BatchPlanNode
Source§impl ExprRewritable<Batch> for BatchDelete
impl ExprRewritable<Batch> for BatchDelete
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchExchange
impl ExprRewritable<Batch> for BatchExchange
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchExpand
impl ExprRewritable<Batch> for BatchExpand
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchFileScan
impl ExprRewritable<Batch> for BatchFileScan
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchFilter
impl ExprRewritable<Batch> for BatchFilter
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchGroupTopN
impl ExprRewritable<Batch> for BatchGroupTopN
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchHashAgg
impl ExprRewritable<Batch> for BatchHashAgg
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchHashJoin
impl ExprRewritable<Batch> for BatchHashJoin
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchHopWindow
impl ExprRewritable<Batch> for BatchHopWindow
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchIcebergScan
impl ExprRewritable<Batch> for BatchIcebergScan
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchInsert
impl ExprRewritable<Batch> for BatchInsert
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchKafkaScan
impl ExprRewritable<Batch> for BatchKafkaScan
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchLimit
impl ExprRewritable<Batch> for BatchLimit
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchLogSeqScan
impl ExprRewritable<Batch> for BatchLogSeqScan
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchLookupJoin
impl ExprRewritable<Batch> for BatchLookupJoin
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchMaxOneRow
impl ExprRewritable<Batch> for BatchMaxOneRow
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchMySqlQuery
impl ExprRewritable<Batch> for BatchMySqlQuery
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchNestedLoopJoin
impl ExprRewritable<Batch> for BatchNestedLoopJoin
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchOverWindow
impl ExprRewritable<Batch> for BatchOverWindow
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchPostgresQuery
impl ExprRewritable<Batch> for BatchPostgresQuery
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchProject
impl ExprRewritable<Batch> for BatchProject
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchProjectSet
impl ExprRewritable<Batch> for BatchProjectSet
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchSeqScan
impl ExprRewritable<Batch> for BatchSeqScan
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchSimpleAgg
impl ExprRewritable<Batch> for BatchSimpleAgg
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchSort
impl ExprRewritable<Batch> for BatchSort
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchSortAgg
impl ExprRewritable<Batch> for BatchSortAgg
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchSource
impl ExprRewritable<Batch> for BatchSource
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchSysSeqScan
impl ExprRewritable<Batch> for BatchSysSeqScan
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchTableFunction
impl ExprRewritable<Batch> for BatchTableFunction
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchTopN
impl ExprRewritable<Batch> for BatchTopN
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchUnion
impl ExprRewritable<Batch> for BatchUnion
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>
Source§impl ExprRewritable<Batch> for BatchUpdate
impl ExprRewritable<Batch> for BatchUpdate
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl ExprRewritable<Batch> for BatchValues
impl ExprRewritable<Batch> for BatchValues
fn has_rewritable_expr(&self) -> bool
fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef
Source§impl InfallibleRule<Batch> for BatchIcebergCountStar
impl InfallibleRule<Batch> for BatchIcebergCountStar
Source§impl InfallibleRule<Batch> for BatchProjectMergeRule
impl InfallibleRule<Batch> for BatchProjectMergeRule
Source§impl PlanTreeNode<Batch> for BatchDelete
impl PlanTreeNode<Batch> for BatchDelete
Source§impl PlanTreeNode<Batch> for BatchExchange
impl PlanTreeNode<Batch> for BatchExchange
Source§impl PlanTreeNode<Batch> for BatchExpand
impl PlanTreeNode<Batch> for BatchExpand
Source§impl PlanTreeNode<Batch> for BatchFileScan
impl PlanTreeNode<Batch> for BatchFileScan
Source§impl PlanTreeNode<Batch> for BatchFilter
impl PlanTreeNode<Batch> for BatchFilter
Source§impl PlanTreeNode<Batch> for BatchGroupTopN
impl PlanTreeNode<Batch> for BatchGroupTopN
Source§impl PlanTreeNode<Batch> for BatchHashAgg
impl PlanTreeNode<Batch> for BatchHashAgg
Source§impl PlanTreeNode<Batch> for BatchHashJoin
impl PlanTreeNode<Batch> for BatchHashJoin
Source§impl PlanTreeNode<Batch> for BatchHopWindow
impl PlanTreeNode<Batch> for BatchHopWindow
Source§impl PlanTreeNode<Batch> for BatchIcebergScan
impl PlanTreeNode<Batch> for BatchIcebergScan
Source§impl PlanTreeNode<Batch> for BatchInsert
impl PlanTreeNode<Batch> for BatchInsert
Source§impl PlanTreeNode<Batch> for BatchKafkaScan
impl PlanTreeNode<Batch> for BatchKafkaScan
Source§impl PlanTreeNode<Batch> for BatchLimit
impl PlanTreeNode<Batch> for BatchLimit
Source§impl PlanTreeNode<Batch> for BatchLogSeqScan
impl PlanTreeNode<Batch> for BatchLogSeqScan
Source§impl PlanTreeNode<Batch> for BatchLookupJoin
impl PlanTreeNode<Batch> for BatchLookupJoin
Source§impl PlanTreeNode<Batch> for BatchMaxOneRow
impl PlanTreeNode<Batch> for BatchMaxOneRow
Source§impl PlanTreeNode<Batch> for BatchMySqlQuery
impl PlanTreeNode<Batch> for BatchMySqlQuery
Source§impl PlanTreeNode<Batch> for BatchNestedLoopJoin
impl PlanTreeNode<Batch> for BatchNestedLoopJoin
Source§impl PlanTreeNode<Batch> for BatchOverWindow
impl PlanTreeNode<Batch> for BatchOverWindow
Source§impl PlanTreeNode<Batch> for BatchPostgresQuery
impl PlanTreeNode<Batch> for BatchPostgresQuery
Source§impl PlanTreeNode<Batch> for BatchProject
impl PlanTreeNode<Batch> for BatchProject
Source§impl PlanTreeNode<Batch> for BatchProjectSet
impl PlanTreeNode<Batch> for BatchProjectSet
Source§impl PlanTreeNode<Batch> for BatchSeqScan
impl PlanTreeNode<Batch> for BatchSeqScan
Source§impl PlanTreeNode<Batch> for BatchSimpleAgg
impl PlanTreeNode<Batch> for BatchSimpleAgg
Source§impl PlanTreeNode<Batch> for BatchSort
impl PlanTreeNode<Batch> for BatchSort
Source§impl PlanTreeNode<Batch> for BatchSortAgg
impl PlanTreeNode<Batch> for BatchSortAgg
Source§impl PlanTreeNode<Batch> for BatchSource
impl PlanTreeNode<Batch> for BatchSource
Source§impl PlanTreeNode<Batch> for BatchSysSeqScan
impl PlanTreeNode<Batch> for BatchSysSeqScan
Source§impl PlanTreeNode<Batch> for BatchTableFunction
impl PlanTreeNode<Batch> for BatchTableFunction
Source§impl PlanTreeNode<Batch> for BatchTopN
impl PlanTreeNode<Batch> for BatchTopN
Source§impl PlanTreeNode<Batch> for BatchUnion
impl PlanTreeNode<Batch> for BatchUnion
Source§impl PlanTreeNode<Batch> for BatchUpdate
impl PlanTreeNode<Batch> for BatchUpdate
Source§impl PlanTreeNode<Batch> for BatchValues
impl PlanTreeNode<Batch> for BatchValues
Source§impl PlanTreeNodeBinary<Batch> for BatchHashJoin
impl PlanTreeNodeBinary<Batch> for BatchHashJoin
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<Batch> for BatchNestedLoopJoin
impl PlanTreeNodeBinary<Batch> for BatchNestedLoopJoin
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<Batch> for BatchDelete
impl PlanTreeNodeUnary<Batch> for BatchDelete
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<Batch> for BatchExchange
impl PlanTreeNodeUnary<Batch> for BatchExchange
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<Batch> for BatchExpand
impl PlanTreeNodeUnary<Batch> for BatchExpand
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<Batch> for BatchFilter
impl PlanTreeNodeUnary<Batch> for BatchFilter
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<Batch> for BatchGroupTopN
impl PlanTreeNodeUnary<Batch> for BatchGroupTopN
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<Batch> for BatchHashAgg
impl PlanTreeNodeUnary<Batch> for BatchHashAgg
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<Batch> for BatchHopWindow
impl PlanTreeNodeUnary<Batch> for BatchHopWindow
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<Batch> for BatchInsert
impl PlanTreeNodeUnary<Batch> for BatchInsert
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<Batch> for BatchLimit
impl PlanTreeNodeUnary<Batch> for BatchLimit
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<Batch> for BatchLookupJoin
impl PlanTreeNodeUnary<Batch> for BatchLookupJoin
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<Batch> for BatchMaxOneRow
impl PlanTreeNodeUnary<Batch> for BatchMaxOneRow
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<Batch> for BatchOverWindow
impl PlanTreeNodeUnary<Batch> for BatchOverWindow
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<Batch> for BatchProject
impl PlanTreeNodeUnary<Batch> for BatchProject
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<Batch> for BatchProjectSet
impl PlanTreeNodeUnary<Batch> for BatchProjectSet
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<Batch> for BatchSimpleAgg
impl PlanTreeNodeUnary<Batch> for BatchSimpleAgg
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<Batch> for BatchSort
impl PlanTreeNodeUnary<Batch> for BatchSort
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<Batch> for BatchSortAgg
impl PlanTreeNodeUnary<Batch> for BatchSortAgg
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<Batch> for BatchTopN
impl PlanTreeNodeUnary<Batch> for BatchTopN
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<Batch> for BatchUpdate
impl PlanTreeNodeUnary<Batch> for BatchUpdate
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
impl Eq for Batch
impl StructuralPartialEq for Batch
Auto Trait Implementations§
impl Freeze for Batch
impl RefUnwindSafe for Batch
impl Send for Batch
impl Sync for Batch
impl Unpin for Batch
impl UnwindSafe for Batch
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<Batch> for Vwhere
V: BatchPlanVisitor,
impl<V> PlanVisitor<Batch> for Vwhere
V: BatchPlanVisitor,
§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.