List of all items

Structs

• FlowEngine
• builder::FlowBuilder
• ffi::loader::ColumnDefInfo
• ffi::loader::FFIOperatorLoader
• ffi::loader::LoadedOperatorInfo
• ffi::registry::FFIOperatorRegistry
• stateful::RowNumberProvider
• stateful::StateIterator
• subsystem::FlowSubsystem
• subsystem::FlowSubsystemConfig
• subsystem::FlowSubsystemFactory
• subsystem::intercept::TransactionalFlowInterceptor
• transaction::FlowTransaction
• transaction::FlowTransactionMetrics
• transaction::PendingWrites
• worker::UnitOfWork
• worker::UnitsOfWork
• worker::same::SameThreadedWorker

Enums

• transaction::Pending

Traits

• Operator
• TransformOperator
• TransformOperatorFactory
• stateful::KeyedStateful
• stateful::RawStatefulOperator
• stateful::SingleStateful
• stateful::WindowStateful
• worker::WorkerPool

Functions

• extract::float
• extract::int
• extract::string
• ffi::callbacks::create_host_callbacks
• ffi::callbacks::memory::clear_current_arena
• ffi::callbacks::memory::set_current_arena
• ffi::loader::ffi_operator_loader
• stateful::empty_key
• stateful::internal_state_get
• stateful::internal_state_remove
• stateful::internal_state_set
• stateful::load_or_create_row
• stateful::save_row
• stateful::state_clear
• stateful::state_get
• stateful::state_range
• stateful::state_remove
• stateful::state_scan
• stateful::state_set

Type Aliases

• Result
• builder::OperatorFactory
• ffi::callbacks::state_iterator::StateIteratorHandle
• ffi::callbacks::store_iterator::StoreIteratorHandle