pub fn build_index_dataflow(
        &mut self,
        name: String,
        id: GlobalId,
        index_description: dataflow_types::IndexDesc,
    ) -> DataflowDesc {
        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);
        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: dataflow_types::IndexDesc,
    ) -> DataflowDesc {
        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);
        dataflow
    }
pub fn build_index_dataflow ( & mut self , name : String , id : GlobalId , index_description : dataflow_types :: IndexDesc , ) -> DataflowDesc { 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 ) ; 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
dataflow_types::IndexDesc
&mut self
name
String
id
GlobalId
index_description
dataflow_types::IndexDesc