pub fn build_sink_dataflow_into(
        &mut self,
        dataflow: &mut DataflowDesc,
        id: GlobalId,
        sink_description: SinkDesc,
    ) -> Result<(), CoordError> {
        dataflow.set_as_of(sink_description.as_of.frontier.clone());
        self.import_into_dataflow(&sink_description.from, dataflow)?;
        dataflow.export_sink(id, sink_description);

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

        Ok(())
    }
/// Like `build_sink_dataflow`, but builds the sink dataflow into the
/// existing dataflow description instead of creating one from scratch.
Like `build_sink_dataflow`, but builds the sink dataflow into the
existing dataflow description instead of creating one from scratch.
Like ` build_sink_dataflow ` but builds the sink dataflow into the existing dataflow description instead of creating one from scratch .
pub fn build_sink_dataflow_into(
        &mut self,
        dataflow: &mut DataflowDesc,
        id: GlobalId,
        sink_description: SinkDesc,
    ) -> Result<(), CoordError> {
        dataflow.set_as_of(sink_description.as_of.frontier.clone());
        self.import_into_dataflow(&sink_description.from, dataflow)?;
        dataflow.export_sink(id, sink_description);
        // Optimize the dataflow across views, and any other ways that appeal.
        mz_transform::optimize_dataflow(dataflow, self.catalog.enabled_indexes())?;
        Ok(())
    }
pub fn build_sink_dataflow_into ( & mut self , dataflow : & mut DataflowDesc , id : GlobalId , sink_description : SinkDesc , ) -> Result < ( ) , CoordError > { dataflow . set_as_of ( sink_description . as_of . frontier . clone ( ) ) ; self . import_into_dataflow ( & sink_description . from , dataflow ) ? ; dataflow . export_sink ( id , sink_description ) ; // Optimize the dataflow across views, and any other ways that appeal. mz_transform :: optimize_dataflow ( dataflow , self . catalog . enabled_indexes ( ) ) ? ; Ok ( ( ) ) }
Like `build_sink_dataflow`, but builds the sink dataflow into the
existing dataflow description instead of creating one from scratch.
Like ` build_sink_dataflow ` but builds the sink dataflow into the existing dataflow description instead of creating one from scratch .
&mut self
dataflow
&mut DataflowDesc
id
GlobalId
sink_description
SinkDesc