pub fn build_sink_dataflow(
        &mut self,
        name: String,
        id: GlobalId,
        sink_description: dataflow_types::SinkDesc,
    ) -> DataflowDesc {
        let mut dataflow = DataflowDesc::new(name);
        dataflow.set_as_of(sink_description.as_of.frontier.clone());
        self.import_into_dataflow(&sink_description.from, &mut dataflow);
        dataflow.export_sink(id, sink_description);
        dataflow
    }
/// 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).
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).
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(
        &mut self,
        name: String,
        id: GlobalId,
        sink_description: dataflow_types::SinkDesc,
    ) -> DataflowDesc {
        let mut dataflow = DataflowDesc::new(name);
        dataflow.set_as_of(sink_description.as_of.frontier.clone());
        self.import_into_dataflow(&sink_description.from, &mut dataflow);
        dataflow.export_sink(id, sink_description);
        dataflow
    }
pub fn build_sink_dataflow ( & mut self , name : String , id : GlobalId , sink_description : dataflow_types :: SinkDesc , ) -> DataflowDesc { let mut dataflow = DataflowDesc :: new ( name ) ; dataflow . set_as_of ( sink_description . as_of . frontier . clone ( ) ) ; self . import_into_dataflow ( & sink_description . from , & mut dataflow ) ; dataflow . export_sink ( id , sink_description ) ; dataflow }
Builds a dataflow description for the sink with the specified name,
ID, source, and output connector.
Builds a dataflow description for the sink with the specified name ID source and output connector .
&mut self
name
String
id
GlobalId
sink_description
dataflow_types::SinkDesc
&mut self
name
String
id
GlobalId
sink_description
dataflow_types::SinkDesc