Struct coord::coord::dataflow_builder::DataflowBuilder

pub struct DataflowBuilder<'a> {
    pub catalog: &'a CatalogState,
    pub indexes: &'a ArrangementFrontiers<Timestamp>,
    pub persister: &'a PersisterWithConfig,
    pub storage: &'a Controller<Box<dyn Client>>,
}

Borrows of catalog and indexes sufficient to build dataflow descriptions.

Fields

catalog: &'a CatalogState

indexes: &'a ArrangementFrontiers<Timestamp>

persister: &'a PersisterWithConfig

storage: &'a Controller<Box<dyn Client>>

A handle to the storage abstraction, which describe sources from their identifier.

Implementations

impl<'a> DataflowBuilder<'a>

fn import_into_dataflow(
    &mut self,
    id: &GlobalId,
    dataflow: &mut DataflowDesc
) -> Result<(), CoordError>

Imports the view, source, or table with id into the provided dataflow description.

pub fn import_view_into_dataflow(
    &mut self,
    view_id: &GlobalId,
    view: &OptimizedMirRelationExpr,
    dataflow: &mut DataflowDesc
) -> Result<(), CoordError>

Imports the view with the specified ID and expression into the provided dataflow description.

pub fn build_index_dataflow(
    &mut self,
    name: String,
    id: GlobalId,
    index_description: IndexDesc
) -> Result<DataflowDesc, CoordError>

Builds a dataflow description for the index with the specified ID.

pub fn build_sink_dataflow(
    &mut self,
    name: String,
    id: GlobalId,
    sink_description: SinkDesc
) -> Result<DataflowDesc, CoordError>

Builds a dataflow description for the sink with the specified name, ID, source, and output connector.

For as long as this dataflow is active, id can be used to reference the sink (primarily to drop it, at the moment).

pub fn build_sink_dataflow_into(
    &mut self,
    dataflow: &mut DataflowDesc,
    id: GlobalId,
    sink_description: SinkDesc
) -> Result<(), CoordError>

Like build_sink_dataflow, but builds the sink dataflow into the existing dataflow description instead of creating one from scratch.