Struct mz_catalog::memory::objects::ContinualTask

pub struct ContinualTask {
    pub create_sql: String,
    pub global_id: GlobalId,
    pub input_id: GlobalId,
    pub with_snapshot: bool,
    pub raw_expr: Arc<HirRelationExpr>,
    pub desc: RelationDesc,
    pub resolved_ids: ResolvedIds,
    pub dependencies: DependencyIds,
    pub cluster_id: ClusterId,
    pub initial_as_of: Option<Antichain<Timestamp>>,
}

Fields

create_sql: String

Parse-able SQL that defines this continual task.

global_id: GlobalId

GlobalId used to reference this continual task from outside the catalog.

input_id: GlobalId

GlobalId of the collection that we read into this continual task.

with_snapshot: bool

raw_expr: Arc<HirRelationExpr>

ContinualTasks are self-referential. We make this work by using a placeholder LocalId for the CT itself through name resolution and planning. Then we fill in the real GlobalId before constructing this catalog item.

desc: RelationDesc

Columns for this continual task.

resolved_ids: ResolvedIds

Other catalog items that this continual task references, determined at name resolution.

dependencies: DependencyIds

All of the catalog objects that are referenced by this continual task.

cluster_id: ClusterId

Cluster that this continual task runs on.

initial_as_of: Option<Antichain<Timestamp>>

See the comment on MaterializedView::initial_as_of.

Implementations

impl ContinualTask

pub fn global_id(&self) -> GlobalId

The single GlobalId used to reference this continual task.

Trait Implementations

impl Clone for ContinualTask

fn clone(&self) -> ContinualTask

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ContinualTask

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

Formats the value using the given formatter.

impl Serialize for ContinualTask

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.