Struct StreamLocalityProvider 

pub struct StreamLocalityProvider {
    pub base: PlanBase<Stream>,
    core: LocalityProvider<StreamPlanRef>,
}

StreamLocalityProvider implements super::LogicalLocalityProvider

Fields

base: PlanBase<Stream>

core: LocalityProvider<StreamPlanRef>

Implementations

impl StreamLocalityProvider

pub fn new(core: LocalityProvider<PlanRef>) -> Self

pub fn locality_columns(&self) -> &[usize]

impl StreamLocalityProvider

fn build_state_catalog( &self, state: &mut BuildFragmentGraphState, ) -> TableCatalog

Build the state table catalog for buffering input data Schema: same as input schema (locality handled by primary key ordering) Key: locality_columns (vnode handled internally by StateTable)

fn build_sort_buffer_catalog( &self, state: &mut BuildFragmentGraphState, ) -> TableCatalog

Build the ephemeral sorted log table catalog for the post-backfill sort buffer. Schema: all input columns + gen (epoch generation) + op + seq Key: gen + locality_columns + input stream key + seq

Buffered changes of one epoch are written with the current epoch as gen, so that a prefix scan on gen replays exactly the changes of that epoch in locality order. seq is a monotonically increasing sequence number within the epoch, making every buffered change a unique key (append-only writes, per-key order preserved). op records the change kind. Old generations are cleaned by the state-clean watermark on gen.

fn build_progress_catalog( &self, state: &mut BuildFragmentGraphState, ) -> TableCatalog

Build the progress table catalog for tracking backfill progress Schema: | vnode | pk(locality columns + input stream keys) | backfill_finished | row_count | Key: | vnode | pk(locality columns + input stream keys) |

Methods from Deref<Target = PlanBase<Stream>>

pub fn clone_with_new_plan_id(&self) -> Self

pub fn clone_with_new_distribution(&self, dist: Distribution) -> Self

Clone the plan node with a new distribution.

Panics if the plan node is not physical.

Trait Implementations

impl Clone for StreamLocalityProvider

fn clone(&self) -> StreamLocalityProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamLocalityProvider

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

Formats the value using the given formatter.

impl Deref for StreamLocalityProvider

type Target = PlanBase<Stream>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Distill for StreamLocalityProvider

fn distill<'a>(&self) -> XmlNode<'a>

fn distill_to_string(&self) -> String

impl Eq for StreamLocalityProvider

impl ExprRewritable<Stream> for StreamLocalityProvider

fn has_rewritable_expr(&self) -> bool

fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef

impl ExprVisitable for StreamLocalityProvider

fn visit_exprs(&self, _v: &mut dyn ExprVisitor)

impl Hash for StreamLocalityProvider

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for StreamLocalityProvider

fn eq(&self, other: &StreamLocalityProvider) -> 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 PlanNodeMeta for StreamLocalityProvider

const NODE_TYPE: StreamPlanNodeType = StreamPlanNodeType::StreamLocalityProvider

type Convention = Stream

fn plan_base(&self) -> &PlanBase<Stream>

Get the reference to the PlanBase with corresponding convention.

impl PlanTreeNode<Stream> for StreamLocalityProvider

fn clone_with_inputs(&self, inputs: &[PlanRef<Stream>]) -> PlanRef<Stream>

Clone the node with a list of new inputs.

fn inputs(&self) -> SmallVec<[PlanRef<Stream>; 2]>

Get input nodes of the plan.

impl PlanTreeNodeUnary<Stream> for StreamLocalityProvider

fn input(&self) -> PlanRef

fn clone_with_input(&self, input: PlanRef) -> Self

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.

impl StreamNode for StreamLocalityProvider

fn to_stream_prost_body( &self, state: &mut BuildFragmentGraphState, ) -> PbNodeBody

impl StreamPlanNode for StreamLocalityProvider

impl StructuralPartialEq for StreamLocalityProvider