Struct CreateSinkStatement 

pub struct CreateSinkStatement {
    pub name: ObjectName,
    pub from: SinkFrom,
    pub or_replace: bool,
    pub if_not_exists: bool,
    pub filter: Option<Expr>,
    pub connector_type: Option<String>,
    pub connector_options: HashMap<String, String>,
    pub format: Option<FormatSpec>,
}

Parsed CREATE SINK statement.

Fields

name: ObjectName

Sink name.

from: SinkFrom

Sink input.

or_replace: bool

Replace an existing sink.

if_not_exists: bool

Ignore an existing sink.

filter: Option<Expr>

Optional row filter.

connector_type: Option<String>

Connector type (e.g., “KAFKA”) from INTO KAFKA (...) syntax

connector_options: HashMap<String, String>

Connector-specific options (from INTO KAFKA (...))

format: Option<FormatSpec>

Format specification (e.g., FORMAT JSON)

Trait Implementations

impl Clone for CreateSinkStatement

fn clone(&self) -> CreateSinkStatement

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CreateSinkStatement

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

Formats the value using the given formatter.

impl PartialEq for CreateSinkStatement

fn eq(&self, other: &CreateSinkStatement) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for CreateSinkStatement