pub fn build_index_dataflow(
        &mut self,
        name: String,
        id: GlobalId,
        index_description: IndexDesc,
    ) -> Result<DataflowDesc, CoordError> {
        let on_entry = self.catalog.get_by_id(&index_description.on_id);
        let on_type = on_entry.desc().unwrap().typ().clone();
        let mut dataflow = DataflowDesc::new(name);
        self.import_into_dataflow(&index_description.on_id, &mut dataflow)?;
        dataflow.export_index(id, index_description, on_type);

        // Optimize the dataflow across views, and any other ways that appeal.
        mz_transform::optimize_dataflow(&mut dataflow, self.catalog.enabled_indexes())?;

        Ok(dataflow)
    }
/// Builds a dataflow description for the index with the specified ID.
Builds a dataflow description for the index with the specified ID.
Builds a dataflow description for the index with the specified ID .
pub fn build_index_dataflow(
        &mut self,
        name: String,
        id: GlobalId,
        index_description: IndexDesc,
    ) -> Result<DataflowDesc, CoordError> {
        let on_entry = self.catalog.get_by_id(&index_description.on_id);
        let on_type = on_entry.desc().unwrap().typ().clone();
        let mut dataflow = DataflowDesc::new(name);
        self.import_into_dataflow(&index_description.on_id, &mut dataflow)?;
        dataflow.export_index(id, index_description, on_type);
        // Optimize the dataflow across views, and any other ways that appeal.
        mz_transform::optimize_dataflow(&mut dataflow, self.catalog.enabled_indexes())?;
        Ok(dataflow)
    }
pub fn build_index_dataflow ( & mut self , name : String , id : GlobalId , index_description : IndexDesc , ) -> Result < DataflowDesc , CoordError > { let on_entry = self . catalog . get_by_id ( & index_description . on_id ) ; let on_type = on_entry . desc ( ) . unwrap ( ) . typ ( ) . clone ( ) ; let mut dataflow = DataflowDesc :: new ( name ) ; self . import_into_dataflow ( & index_description . on_id , & mut dataflow ) ? ; dataflow . export_index ( id , index_description , on_type ) ; // Optimize the dataflow across views, and any other ways that appeal. mz_transform :: optimize_dataflow ( & mut dataflow , self . catalog . enabled_indexes ( ) ) ? ; Ok ( dataflow ) }
Builds a dataflow description for the index with the specified ID.
Builds a dataflow description for the index with the specified ID .
&mut self
name
String
id
GlobalId
index_description
IndexDesc