pub struct FlowEngine { /* private fields */ }Implementations§
Source§impl FlowEngine
impl FlowEngine
pub fn process( &self, txn: &mut FlowTransaction, change: Change, flow_id: FlowId, ) -> Result<()>
pub fn process_tick( &self, txn: &mut FlowTransaction, flow_id: FlowId, timestamp: DateTime, ) -> Result<()>
Source§impl FlowEngine
impl FlowEngine
pub fn register( &mut self, txn: &mut CommandTransaction, flow: FlowDag, ) -> Result<()>
pub fn register_with_transaction( &mut self, txn: &mut Transaction<'_>, flow: FlowDag, ) -> Result<()>
Source§impl FlowEngine
impl FlowEngine
pub fn new( catalog: Catalog, executor: Executor, event_bus: EventBus, runtime_context: RuntimeContext, custom_operators: Arc<HashMap<String, OperatorFactory>>, ) -> Self
Sourcepub fn clear(&mut self)
pub fn clear(&mut self)
Clears all registered flows, operators, sources, sinks, dependency graph, and backfill versions
pub fn get_dependency_graph(&self) -> FlowDependencyGraph
pub fn get_flows_depending_on_table(&self, table_id: TableId) -> Vec<FlowId>
pub fn get_flows_depending_on_view(&self, view_id: ViewId) -> Vec<FlowId>
pub fn get_flow_producing_view(&self, view_id: ViewId) -> Option<FlowId>
pub fn calculate_execution_order(&self) -> Vec<FlowId>
Auto Trait Implementations§
impl Freeze for FlowEngine
impl !RefUnwindSafe for FlowEngine
impl Send for FlowEngine
impl Sync for FlowEngine
impl Unpin for FlowEngine
impl UnsafeUnpin for FlowEngine
impl !UnwindSafe for FlowEngine
Blanket Implementations§
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
Source§impl<T> GetSetFdFlags for T
impl<T> GetSetFdFlags for T
Source§fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
Query the “status” flags for the
self file descriptor.Source§fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
Source§fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: AsFilelike,
fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: AsFilelike,
Set the “status” flags for the
self file descriptor. Read moreSource§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§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 moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request