pub struct DataflowBuilder<'a> {
    pub catalog: &'a CatalogState,
    pub compute: ComputeInstanceSnapshot,
    pub ignored_indexes: BTreeSet<GlobalId>,
    recursion_guard: RecursionGuard,
}
Expand description

Borrows of catalog and indexes sufficient to build dataflow descriptions.

Fields§

§catalog: &'a CatalogState§compute: ComputeInstanceSnapshot

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.

§ignored_indexes: BTreeSet<GlobalId>

Indexes to be ignored even if they are present in the catalog.

§recursion_guard: RecursionGuard

A guard for recursive operations in this DataflowBuilder instance.

Implementations§

source§

impl<'a> DataflowBuilder<'a>

source

pub fn new(catalog: &'a CatalogState, compute: ComputeInstanceSnapshot) -> Self

source

pub fn ignore_indexes(&mut self, indexes: impl Iterator<Item = GlobalId>)

source

pub fn import_into_dataflow( &mut self, id: &GlobalId, dataflow: &mut DataflowDesc ) -> Result<(), AdapterError>

Imports the view, source, or table with id into the provided dataflow description.

source

pub fn import_view_into_dataflow( &mut self, view_id: &GlobalId, view: &OptimizedMirRelationExpr, dataflow: &mut DataflowDesc ) -> Result<(), AdapterError>

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.

source

pub fn build_sink_dataflow( &mut self, name: String, id: GlobalId, sink_description: ComputeSinkDesc ) -> Result<(DataflowDesc, DataflowMetainfo), AdapterError>

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).

source

pub fn build_sink_dataflow_into( &mut self, dataflow: &mut DataflowDesc, id: GlobalId, sink_description: ComputeSinkDesc ) -> Result<DataflowMetainfo, AdapterError>

Like build_sink_dataflow, but builds the sink dataflow into the existing dataflow description instead of creating one from scratch.

source

fn monotonic_source(&self, source: &Source) -> bool

Determine the given source’s monotonicity.

source

fn monotonic_view(&self, id: GlobalId) -> bool

Determine the given view’s monotonicity.

This recursively traverses the expressions of all (materialized) views involved in the given view’s query expression. If this becomes a performance problem, we could add the monotonicity information of views into the catalog instead.

source

fn monotonic_view_inner( &self, id: GlobalId, memo: &mut BTreeMap<GlobalId, bool> ) -> Result<bool, RecursionLimitError>

source§

impl DataflowBuilder<'_>

source

pub fn sufficient_collections<'a, I>(&self, ids: I) -> CollectionIdBundlewhere I: IntoIterator<Item = &'a GlobalId>,

Identifies a bundle of storage and compute collection ids sufficient for building a dataflow for the identifiers in ids out of the indexes available in this compute instance.

source

pub fn indexes_on( &self, id: GlobalId ) -> impl Iterator<Item = (GlobalId, &Index)>

source§

impl<'a> DataflowBuilder<'a>

Trait Implementations§

source§

impl<'a> CheckedRecursion for DataflowBuilder<'a>

source§

fn recursion_guard(&self) -> &RecursionGuard

Extracts a reference to the recursion guard embedded within the type.
source§

fn checked_recur<F, T, E>(&self, f: F) -> Result<T, E>where F: FnOnce(&Self) -> Result<T, E>, E: From<RecursionLimitError>,

Checks whether it is safe to recur and calls f if so. Read more
source§

fn checked_recur_mut<F, T, E>(&mut self, f: F) -> Result<T, E>where F: FnOnce(&mut Self) -> Result<T, E>, E: From<RecursionLimitError>,

Like CheckedRecursion::checked_recur, but operates on a mutable reference to Self.
source§

impl<'a> Debug for DataflowBuilder<'a>

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
source§

impl IndexOracle for DataflowBuilder<'_>

source§

fn indexes_on( &self, id: GlobalId ) -> Box<dyn Iterator<Item = (GlobalId, &[MirScalarExpr])> + '_>

Returns an iterator over the indexes that exist on the identified collection. Read more

Auto Trait Implementations§

§

impl<'a> !RefUnwindSafe for DataflowBuilder<'a>

§

impl<'a> Send for DataflowBuilder<'a>

§

impl<'a> !Sync for DataflowBuilder<'a>

§

impl<'a> Unpin for DataflowBuilder<'a>

§

impl<'a> !UnwindSafe for DataflowBuilder<'a>

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> FutureExt for T

source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoRequest<T> for T

source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
source§

impl<T> Pointable for T

source§

const ALIGN: usize = _

The alignment of pointer.
§

type Init = T

The type for initializers.
source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<P, R> ProtoType<R> for Pwhere R: RustType<P>,

source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

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
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more