Struct mz_coord::coord::dataflow_builder::DataflowBuilder
source · [−]pub struct DataflowBuilder<'a, T> {
pub catalog: &'a CatalogState,
pub compute: ComputeController<'a, T>,
}Expand description
Borrows of catalog and indexes sufficient to build dataflow descriptions.
Fields
catalog: &'a CatalogStatecompute: ComputeController<'a, T>A handle to the compute abstraction, which describes indexes by identifier.
This can also be used to grab a handle to the storage abstraction, through
its storage_mut() method.
Implementations
sourceimpl<'a> DataflowBuilder<'a, Timestamp>
impl<'a> DataflowBuilder<'a, Timestamp>
sourcefn import_into_dataflow(
&mut self,
id: &GlobalId,
dataflow: &mut DataflowDesc
) -> Result<(), CoordError>
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.
sourcepub fn import_view_into_dataflow(
&mut self,
view_id: &GlobalId,
view: &OptimizedMirRelationExpr,
dataflow: &mut DataflowDesc
) -> Result<(), CoordError>
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.
You should generally prefer calling
DataflowBuilder::import_into_dataflow, which can handle objects of
any type as long as they exist in the catalog. This method exists for
when the view does not exist in the catalog, e.g., because it is
identified by a GlobalId::Transient.
sourcepub fn build_index_dataflow(
&mut self,
id: GlobalId
) -> Result<DataflowDesc, CoordError>
pub fn build_index_dataflow(
&mut self,
id: GlobalId
) -> Result<DataflowDesc, CoordError>
Builds a dataflow description for the index with the specified ID.
sourcepub fn build_sink_dataflow(
&mut self,
name: String,
id: GlobalId,
sink_description: SinkDesc
) -> Result<DataflowDesc, CoordError>
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 connection.
For as long as this dataflow is active, id can be used to reference
the sink (primarily to drop it, at the moment).
sourcepub fn build_sink_dataflow_into(
&mut self,
dataflow: &mut DataflowDesc,
id: GlobalId,
sink_description: SinkDesc
) -> Result<(), CoordError>
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.
sourceimpl<T: Copy> DataflowBuilder<'_, T>
impl<T: Copy> DataflowBuilder<'_, T>
sourcepub fn index_oracle(&self) -> ComputeInstanceIndexOracle<'_, T>
pub fn index_oracle(&self) -> ComputeInstanceIndexOracle<'_, T>
Creates a new index oracle for the same compute instance as the dataflow builder.
Auto Trait Implementations
impl<'a, T> !RefUnwindSafe for DataflowBuilder<'a, T>
impl<'a, T> !Send for DataflowBuilder<'a, T>
impl<'a, T> !Sync for DataflowBuilder<'a, T>
impl<'a, T> Unpin for DataflowBuilder<'a, T>
impl<'a, T> !UnwindSafe for DataflowBuilder<'a, T>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T in a tonic::Request
sourceimpl<P, R> ProtoType<R> for P where
R: RustType<P>,
impl<P, R> ProtoType<R> for P where
R: RustType<P>,
sourcefn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See RustType::from_proto.
sourcefn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See RustType::into_proto.
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more