Struct mz_adapter::catalog::Ingestion

pub struct Ingestion {
    pub desc: SourceDesc,
    pub source_imports: BTreeSet<GlobalId>,
    pub subsource_exports: BTreeMap<GlobalId, usize>,
    pub cluster_id: ClusterId,
    pub remap_collection_id: Option<GlobalId>,
}

Fields

desc: SourceDesc

source_imports: BTreeSet<GlobalId>

subsource_exports: BTreeMap<GlobalId, usize>

The additional subsource exports of this ingestion. Each collection identified by its GlobalId will contain the contents of this ingestion’s output stream that is identified by the index.

This map does not include the export of the source associated with the ingestion itself

cluster_id: ClusterId

remap_collection_id: Option<GlobalId>

The ID of this collection’s remap/progress collection.

Trait Implementations

impl Clone for Ingestion

fn clone(&self) -> Ingestion

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Ingestion

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

Formats the value using the given formatter.

impl Serialize for Ingestion

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

Serialize this value into the given Serde serializer.