Enum AlterSinkOperation 

pub enum AlterSinkOperation {
    RenameSink {
        sink_name: ObjectName,
    },
    ChangeOwner {
        new_owner_name: Ident,
    },
    SetSchema {
        new_schema_name: ObjectName,
    },
    SetParallelism {
        parallelism: SetVariableValue,
        deferred: bool,
    },
    SetConfig {
        entries: Vec<SqlOption>,
    },
    ResetConfig {
        keys: Vec<ObjectName>,
    },
    SwapRenameSink {
        target_sink: ObjectName,
    },
    SetSinkRateLimit {
        rate_limit: i32,
    },
    AlterConnectorProps {
        alter_props: Vec<SqlOption>,
    },
    SetStreamingEnableUnalignedJoin {
        enable: bool,
    },
}

Variants

RenameSink

Fields

sink_name: ObjectName

ChangeOwner

Fields

new_owner_name: Ident

SetSchema

Fields

new_schema_name: ObjectName

SetParallelism

SET PARALLELISM TO <parallelism> [ DEFERRED ]

Fields

parallelism: SetVariableValue

deferred: bool

SetConfig

SET CONFIG (key = value, ...)

Fields

entries: Vec<SqlOption>

ResetConfig

RESET CONFIG (key, ...)

Fields

keys: Vec<ObjectName>

SwapRenameSink

SWAP WITH <sink_name>

Fields

target_sink: ObjectName

SetSinkRateLimit

Fields

rate_limit: i32

AlterConnectorProps

Fields

alter_props: Vec<SqlOption>

SetStreamingEnableUnalignedJoin

Fields

enable: bool

Trait Implementations

impl Clone for AlterSinkOperation

fn clone(&self) -> AlterSinkOperation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AlterSinkOperation

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

Formats the value using the given formatter.

impl Display for AlterSinkOperation

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

Formats the value using the given formatter.

impl Hash for AlterSinkOperation

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 AlterSinkOperation

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

impl StructuralPartialEq for AlterSinkOperation