Enum StreamingJob

pub enum StreamingJob {
    MaterializedView(Table),
    Sink(Sink, Option<(Table, Option<PbSource>)>),
    Table(Option<PbSource>, Table, TableJobType),
    Index(Index, Table),
    Source(PbSource),
}

Variants

MaterializedView(Table)

Sink(Sink, Option<(Table, Option<PbSource>)>)

Table(Option<PbSource>, Table, TableJobType)

Index(Index, Table)

Source(PbSource)

Implementations

impl StreamingJob

pub const fn is_materialized_view(&self) -> bool

Returns true if the enum is StreamingJob::MaterializedView otherwise false

pub const fn is_sink(&self) -> bool

Returns true if the enum is StreamingJob::Sink otherwise false

pub const fn is_table(&self) -> bool

Returns true if the enum is StreamingJob::Table otherwise false

pub const fn is_index(&self) -> bool

Returns true if the enum is StreamingJob::Index otherwise false

pub const fn is_source(&self) -> bool

Returns true if the enum is StreamingJob::Source otherwise false

impl StreamingJob

pub fn mark_created(&mut self)

pub fn mark_initialized(&mut self)

impl StreamingJob

pub fn set_id(&mut self, id: u32)

pub fn set_table_fragment_id(&mut self, id: FragmentId)

Set the fragment id where the table is materialized.

pub fn set_table_vnode_count(&mut self, vnode_count: usize)

Set the vnode count of the table.

pub fn set_dml_fragment_id(&mut self, id: Option<FragmentId>)

Set the fragment id where the table dml is received.

pub fn id(&self) -> u32

pub fn mv_table(&self) -> Option<u32>

pub fn table(&self) -> Option<&Table>

Returns the reference to the Table of the job if it exists.

pub fn schema_id(&self) -> u32

pub fn database_id(&self) -> u32

pub fn name(&self) -> String

pub fn owner(&self) -> u32

pub fn job_type_str(&self) -> &'static str

pub fn definition(&self) -> String

pub fn table_version_id(&self) -> Option<TableVersionId>

Returns the TableVersionId if this job is Table.

pub fn create_type(&self) -> CreateType

pub fn dependent_relations(&self) -> Vec<u32>

pub fn dependent_secret_ids(&self) -> MetaResult<HashSet<u32>>

Trait Implementations

impl Clone for StreamingJob

fn clone(&self) -> StreamingJob

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingJob

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

Formats the value using the given formatter.

impl From<&StreamingJob> for DdlType

fn from(job: &StreamingJob) -> Self

Converts to this type from the input type.

impl<'_enum> From<&'_enum StreamingJob> for StreamingJobDiscriminants

fn from(val: &'_enum StreamingJob) -> StreamingJobDiscriminants

Converts to this type from the input type.

impl From<StreamingJob> for StreamingJobDiscriminants

fn from(val: StreamingJob) -> StreamingJobDiscriminants

Converts to this type from the input type.