pub struct StreamingQueryBuilder { /* private fields */ }Expand description
Builder for constructing a StreamingQuery from pre-compiled components.
Each pipeline is added as a triplet: (ExecutablePipeline, PipelineBridge, BridgeConsumer)
with a corresponding output schema. The builder validates that all parallel vectors
have equal length before producing the query.
Implementations§
Source§impl StreamingQueryBuilder
impl StreamingQueryBuilder
Sourcepub fn add_pipeline(
self,
executable: ExecutablePipeline,
bridge: PipelineBridge,
consumer: BridgeConsumer,
schema: Arc<RowSchema>,
) -> Self
pub fn add_pipeline( self, executable: ExecutablePipeline, bridge: PipelineBridge, consumer: BridgeConsumer, schema: Arc<RowSchema>, ) -> Self
Adds a pipeline triplet (executable + bridge + consumer) with its output schema.
Sourcepub fn with_config(self, config: QueryConfig) -> Self
pub fn with_config(self, config: QueryConfig) -> Self
Sets the query configuration.
Sourcepub fn with_metadata(self, metadata: QueryMetadata) -> Self
pub fn with_metadata(self, metadata: QueryMetadata) -> Self
Sets the compilation metadata.
Sourcepub fn build(self) -> Result<StreamingQuery, QueryError>
pub fn build(self) -> Result<StreamingQuery, QueryError>
Builds the StreamingQuery.
§Errors
Returns QueryError::NoPipelines if no pipelines were added.
Returns QueryError::Build if the parallel vectors have mismatched lengths.
Auto Trait Implementations§
impl Freeze for StreamingQueryBuilder
impl !RefUnwindSafe for StreamingQueryBuilder
impl Send for StreamingQueryBuilder
impl Sync for StreamingQueryBuilder
impl Unpin for StreamingQueryBuilder
impl UnsafeUnpin for StreamingQueryBuilder
impl !UnwindSafe for StreamingQueryBuilder
Blanket Implementations§
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.