Struct StreamAsOfJoin 

pub struct StreamAsOfJoin {
    pub base: PlanBase<Stream>,
    core: Join<StreamPlanRef>,
    eq_join_predicate: EqJoinPredicate,
    is_append_only: bool,
    inequality_desc: AsOfJoinDesc,
    join_encoding_type: JoinEncodingType,
}

StreamAsOfJoin implements super::LogicalJoin with hash tables.

Fields

base: PlanBase<Stream>

core: Join<StreamPlanRef>

eq_join_predicate: EqJoinPredicate

The join condition must be equivalent to logical.on, but separated into equal and non-equal parts to facilitate execution later

is_append_only: bool

Whether can optimize for append-only stream. It is true if input of both side is append-only

inequality_desc: AsOfJoinDesc

inequality description

join_encoding_type: JoinEncodingType

Determine which encoding will be used to encode join rows in operator cache.

Implementations

impl StreamAsOfJoin

pub fn new( core: Join<PlanRef>, eq_join_predicate: EqJoinPredicate, inequality_desc: AsOfJoinDesc, ) -> Result<Self>

pub fn join_type(&self) -> JoinType

Get join type

pub fn eq_join_predicate(&self) -> &EqJoinPredicate

Get a reference to the AsOf join’s eq join predicate.

pub fn derive_dist_key_in_join_key(&self) -> Vec<usize>

pub fn infer_internal_table_catalog<I: StreamPlanNodeMetadata>( input: I, join_key_indices: Vec<usize>, dk_indices_in_jk: Vec<usize>, inequality_key_idx: usize, ) -> (TableCatalog, Vec<usize>)

Return stream asof join internal table catalog.

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 StreamAsOfJoin

fn clone(&self) -> StreamAsOfJoin

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamAsOfJoin

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

Formats the value using the given formatter.

impl Deref for StreamAsOfJoin

type Target = PlanBase<Stream>

The resulting type after dereferencing.

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

Dereferences the value.

impl Distill for StreamAsOfJoin

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

fn distill_to_string(&self) -> String

impl ExprRewritable<Stream> for StreamAsOfJoin

fn has_rewritable_expr(&self) -> bool

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

impl ExprVisitable for StreamAsOfJoin

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

impl Hash for StreamAsOfJoin

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 StreamAsOfJoin

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

const NODE_TYPE: StreamPlanNodeType = StreamPlanNodeType::StreamAsOfJoin

type Convention = Stream

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

Get the reference to the PlanBase with corresponding convention.

impl PlanTreeNode<Stream> for StreamAsOfJoin

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

Get input nodes of the plan.

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

Clone the node with a list of new inputs.

impl PlanTreeNodeBinary<Stream> for StreamAsOfJoin

fn left(&self) -> PlanRef

fn right(&self) -> PlanRef

fn clone_with_left_right(&self, left: PlanRef, right: PlanRef) -> Self

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.

impl StreamNode for StreamAsOfJoin

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

impl Eq for StreamAsOfJoin

impl StreamPlanNode for StreamAsOfJoin

impl StructuralPartialEq for StreamAsOfJoin