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 try_as_materialized_view(self) -> Option<Table>

pub const fn try_as_materialized_view_ref(&self) -> Option<&Table>

pub fn try_as_materialized_view_mut(&mut self) -> Option<&mut Table>

pub fn try_as_sink(self) -> Option<(Sink, Option<(Table, Option<PbSource>)>)>

pub const fn try_as_sink_ref( &self, ) -> Option<(&Sink, &Option<(Table, Option<PbSource>)>)>

pub fn try_as_sink_mut( &mut self, ) -> Option<(&mut Sink, &mut Option<(Table, Option<PbSource>)>)>

pub fn try_as_table(self) -> Option<(Option<PbSource>, Table, TableJobType)>

pub const fn try_as_table_ref( &self, ) -> Option<(&Option<PbSource>, &Table, &TableJobType)>

pub fn try_as_table_mut( &mut self, ) -> Option<(&mut Option<PbSource>, &mut Table, &mut TableJobType)>

pub fn try_as_index(self) -> Option<(Index, Table)>

pub const fn try_as_index_ref(&self) -> Option<(&Index, &Table)>

pub fn try_as_index_mut(&mut self) -> Option<(&mut Index, &mut Table)>

pub fn try_as_source(self) -> Option<PbSource>

pub const fn try_as_source_ref(&self) -> Option<&PbSource>

pub fn try_as_source_mut(&mut self) -> Option<&mut PbSource>

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_vnode_count(&mut self, vnode_count: usize)

Set the vnode count of the table.

pub fn set_info_from_graph(&mut self, graph: &StreamFragmentGraph)

Add some info which is only available in fragment graph to the catalog.

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(&self) -> StreamingJobType

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

pub fn definition(&self) -> String

pub fn object_type(&self) -> ObjectType

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_connection_ids(&self) -> MetaResult<HashSet<u32>>

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

pub async fn verify_version_for_replace( &self, txn: &DatabaseTransaction, ) -> MetaResult<()>

Verify the new version is the next version of the original version.

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 StreamingJobType

fn from(job: &StreamingJob) -> Self

Converts to this type from the input type.