List of all items
Structs
- builder::CustomOperators
- builder::FlowConfig
- builder::FlowConfigurator
- connector::ConnectorRegistry
- engine::FlowEngine
- engine::FlowEngineInner
- host::StandardHostCatalog
- operator::OperatorCell
- operator::append::AppendOperator
- operator::apply::ApplyOperator
- operator::context::native::NativeCatalog
- operator::context::native::NativeDictionary
- operator::context::native::NativeInternalState
- operator::context::native::NativeOperatorContext
- operator::context::native::NativeRowEmit
- operator::context::native::NativeState
- operator::context::native::NativeStore
- operator::context::native::NativeUpdateEmit
- operator::distinct::operator::DistinctOperator
- operator::extend::ExtendOperator
- operator::ffi::FFIOperator
- operator::filter::FilterOperator
- operator::gate::GateOperator
- operator::join::operator::JoinOperator
- operator::join::operator::JoinSideConfig
- operator::map::MapOperator
- operator::native::FlowNativeBridge
- operator::native::LoadedNativeOperatorInfo
- operator::native::NativeBridgedOperator
- operator::native::NativeOperatorAdapter
- operator::native::NativeOperatorColumn
- operator::native::NativeOperatorDescriptor
- operator::native::NativeOperatorLoader
- operator::scan::dictionary::PrimitiveDictionaryOperator
- operator::scan::flow::PrimitiveFlowOperator
- operator::scan::ringbuffer::PrimitiveRingBufferOperator
- operator::scan::series::PrimitiveSeriesOperator
- operator::scan::table::PrimitiveTableOperator
- operator::scan::view::PrimitiveViewOperator
- operator::sink::ringbuffer_view::SinkRingBufferViewOperator
- operator::sink::series_view::SinkSeriesViewOperator
- operator::sink::view::SinkTableViewOperator
- operator::sort::SortOperator
- operator::stateful::StateIterator
- operator::stateful::StateIteratorVersioned
- operator::stateful::counter::Counter
- operator::stateful::row::RowNumberProvider
- operator::stateful::test_utils::test::TestOperator
- operator::take::TakeOperator
- operator::window::accumulator::RowAccumulator
- operator::window::accumulator::StampedAccumulator
- operator::window::accumulator::WindowSlotKey
- operator::window::aggregate::AggregateOperator
- operator::window::aggregation::Aggregation
- operator::window::operator::WindowConfig
- operator::window::operator::WindowOperator
- operator::window::store::FlowWindowStore
- subsystem::FlowSubsystem
- subsystem::factory::FlowSubsystemFactory
- testing::harness::NativeOperatorHarness
- testing::harness::NativeOperatorHarnessBuilder
- transaction::CommittingParams
- transaction::DeferredParams
- transaction::FlowTransactionInner
- transaction::TransactionalParams
- transaction::allocators::FlowAllocators
- transaction::row_allocator::RowAllocatorRegistry
- transaction::slot::OperatorStateSlot
Enums
- error::FlowDispatchError
- error::FlowGraphError
- error::FlowSinkError
- error::FlowStateError
- error::NativeOperatorError
- operator::Operators
- operator::guard::CapabilityViolation
- operator::stateful::counter::CounterDirection
- operator::window::accumulator::AggregateSlot
- operator::window::aggregation::SlotInput
- transaction::FlowTransaction
Traits
- host::HostCatalog
- operator::Operator
- operator::context::native::NativeBridge
- operator::native::BridgedOperator
- operator::stateful::keyed::KeyedStateful
- operator::stateful::raw::RawStatefulOperator
- operator::stateful::single::SingleStateful
- operator::stateful::window::WindowStateful
Functions
- engine::eval::evaluate_operator_config
- operator::guard::check_apply
- operator::guard::check_tick
- operator::guard::enforce_apply_capabilities
- operator::guard::enforce_tick_capability
- operator::native::check_native_abi_tag
- operator::native::native_operator_loader
- operator::native::native_operator_magic
- operator::stateful::row::allocate_row_numbers
- operator::stateful::test_utils::test::assert_row_eq
- operator::stateful::test_utils::test::create_test_transaction
- operator::stateful::test_utils::test::test_key
- operator::stateful::test_utils::test::test_row
- operator::stateful::utils::empty_key
- operator::stateful::utils::internal_state_drop
- operator::stateful::utils::internal_state_get
- operator::stateful::utils::internal_state_range
- operator::stateful::utils::internal_state_range_versioned
- operator::stateful::utils::internal_state_remove
- operator::stateful::utils::internal_state_set
- operator::stateful::utils::load_or_create_row
- operator::stateful::utils::save_row
- operator::stateful::utils::state_clear
- operator::stateful::utils::state_drop
- operator::stateful::utils::state_get
- operator::stateful::utils::state_range
- operator::stateful::utils::state_range_versioned
- operator::stateful::utils::state_remove
- operator::stateful::utils::state_scan_all
- operator::stateful::utils::state_set
- operator::window::aggregate::apply_aggregate_engine
- operator::window::rolling::apply_rolling_engine
- operator::window::rolling::apply_rolling_processing_engine
- operator::window::rolling::tick_expire_rolling_engine
- operator::window::rolling::tick_expire_rolling_processing_engine
- operator::window::tumbling::apply_session_engine
- operator::window::tumbling::apply_sliding_engine
- operator::window::tumbling::apply_tumbling_engine
- operator::window::tumbling::tick_expire_engine_windows
- operator::window::tumbling::tick_expire_session_engine
- subsystem::ffi::load_ffi_operators
- subsystem::ffi::load_native_operators
- testing::assert_backend_parity
Type Aliases
- builder::OperatorFactory
- operator::BoxedOperator
- operator::native::BoxedBridgedOperator
- operator::native::NativeOperatorCreateFn
- transaction::slot::PersistFn