Struct FlowEngine 

pub struct FlowEngine { /* private fields */ }

Implementations

impl FlowEngine

pub async fn create_partition( &self, changes_by_version: BTreeMap<CommitVersion, Vec<(SourceId, Vec<FlowDiff>)>>, ) -> UnitsOfWork

Partition changes from multiple versions into units of work grouped by flow

This method handles the complete partitioning logic:

1. Processes each version’s changes separately
2. Groups units by flow across all versions
3. Maintains version ordering within each flow

Arguments

• changes_by_version - Map of version to (source_id, changes) pairs

Returns

UnitsOfWork where each flow has its units ordered by version

impl FlowEngine

pub async fn process( &self, txn: &mut FlowTransaction, change: FlowChange, flow_id: FlowId, ) -> Result<()>

impl FlowEngine

pub async fn register_without_backfill( &self, txn: &mut StandardCommandTransaction, flow: Flow, ) -> Result<()>

pub async fn register_with_backfill( &self, txn: &mut StandardCommandTransaction, flow: Flow, flow_creation_version: CommitVersion, ) -> Result<()>

impl FlowEngine

pub fn new( evaluator: StandardRowEvaluator, executor: Executor, registry: TransformOperatorRegistry, event_bus: EventBus, operators_dir: Option<PathBuf>, ) -> Self

pub async fn has_registered_flows(&self) -> bool

pub async fn flow_ids(&self) -> HashSet<FlowId>

Returns a set of all currently registered flow IDs

pub async fn clear(&self)

Clears all registered flows, operators, sources, sinks, dependency graph, and backfill versions

pub async fn get_dependency_graph(&self) -> FlowDependencyGraph

pub async fn get_flows_depending_on_table( &self, table_id: TableId, ) -> Vec<FlowId>

pub async fn get_flows_depending_on_view(&self, view_id: ViewId) -> Vec<FlowId>

pub async fn get_flow_producing_view(&self, view_id: ViewId) -> Option<FlowId>

pub async fn calculate_execution_order(&self) -> Vec<FlowId>

Trait Implementations

impl Clone for FlowEngine

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.