Struct StreamSink 

pub struct StreamSink {
    pub base: PlanBase<Stream>,
    input: StreamPlanRef,
    sink_desc: SinkDesc,
    log_store_type: SinkLogStoreType,
}

StreamSink represents a table/connector sink at the very end of the graph.

Fields

base: PlanBase<Stream>

input: StreamPlanRef

sink_desc: SinkDesc

log_store_type: SinkLogStoreType

Implementations

impl StreamSink

pub fn new( input: PlanRef, sink_desc: SinkDesc, log_store_type: SinkLogStoreType, ) -> Self

pub fn sink_desc(&self) -> &SinkDesc

fn derive_iceberg_sink_distribution( input: PlanRef, partition_info: Option<PartitionComputeInfo>, columns: &[ColumnCatalog], ) -> Result<(RequiredDist, PlanRef, Option<usize>)>

pub fn create( _: StreamOptimizedLogicalPlanRoot, name: String, db_name: String, sink_from_table_name: String, target_table: Option<Arc<TableCatalog>>, target_table_mapping: Option<Vec<Option<usize>>>, definition: String, properties: WithOptionsSecResolved, format_desc: Option<SinkFormatDesc>, partition_info: Option<PartitionComputeInfo>, auto_refresh_schema_from_table: Option<Arc<TableCatalog>>, ) -> Result<Self>

fn sink_type_in_prop( properties: &WithOptionsSecResolved, ) -> Result<Option<SinkType>>

fn is_user_force_append_only( properties: &WithOptionsSecResolved, ) -> Result<bool>

fn derive_sink_type( input_append_only: bool, properties: &WithOptionsSecResolved, format_desc: Option<&SinkFormatDesc>, ) -> Result<SinkType>

fn parse_downstream_pk( columns: &[ColumnCatalog], downstream_pk_str: Option<&String>, ) -> Result<Vec<usize>>

Extract user-defined downstream pk columns from with options. Return the indices of the pk columns.

The format of downstream_pk_str should be ‘col1,col2,…’ (delimited by ,) in order to get parsed.

fn infer_kv_log_store_table_catalog(&self) -> TableCatalog

The table schema is: | epoch | seq id | row op | sink columns | Pk is: | epoch | seq id |

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 StreamSink

fn clone(&self) -> StreamSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamSink

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

Formats the value using the given formatter.

impl Deref for StreamSink

type Target = PlanBase<Stream>

The resulting type after dereferencing.

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

Dereferences the value.

impl Distill for StreamSink

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

fn distill_to_string(&self) -> String

impl ExprRewritable<Stream> for StreamSink

fn has_rewritable_expr(&self) -> bool

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

impl ExprVisitable for StreamSink

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

impl Hash for StreamSink

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 StreamSink

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

const NODE_TYPE: StreamPlanNodeType = StreamPlanNodeType::StreamSink

type Convention = Stream

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

Get the reference to the PlanBase with corresponding convention.

impl PlanTreeNode<Stream> for StreamSink

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 StreamSink

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 StreamSink

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

impl Eq for StreamSink

impl StreamPlanNode for StreamSink

impl StructuralPartialEq for StreamSink