Struct CreateSinkStatement 

pub struct CreateSinkStatement {
    pub name: ObjectName,
    pub from: SinkFrom,
    pub with_options: HashMap<String, String>,
    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>,
    pub output_options: HashMap<String, String>,
}

CREATE SINK statement

Fields

name: ObjectName

Sink name

from: SinkFrom

Input query or table

with_options: HashMap<String, String>

Sink connector options (from WITH clause)

or_replace: bool

Whether to replace existing sink

if_not_exists: bool

Whether to skip if exists

filter: Option<Expr>

Optional WHERE filter expression

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)

output_options: HashMap<String, String>

Output options (from WITH (key = ...) after FORMAT)

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

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 TryFrom<CreateSinkStatement> for SinkDefinition

type Error = ParseError

The type returned in the event of a conversion error.

fn try_from(stmt: CreateSinkStatement) -> Result<Self, Self::Error>

Performs the conversion.

impl StructuralPartialEq for CreateSinkStatement