List of all items

Structs

• aggregation::cross_partition::CrossPartitionAggregateStore
• aggregation::gossip_aggregates::AggregateKeyspace
• aggregation::gossip_aggregates::ClusterAggregateResult
• aggregation::gossip_aggregates::GossipAggregateValue
• aggregation::two_phase::HllSketch
• aggregation::two_phase::MergeAggregator
• aggregation::two_phase::PartialAggregate
• alloc::AllocationStats
• alloc::HotPathDetectingAlloc
• alloc::HotPathGuard
• alloc::RingBuffer
• budget::TaskBudget
• checkpoint::barrier::BarrierPollHandle
• checkpoint::barrier::CheckpointBarrier
• checkpoint::barrier::CheckpointBarrierInjector
• checkpoint::unaligned::InFlightChannelData
• checkpoint::unaligned::UnalignedCheckpointConfig
• checkpoint::unaligned::UnalignedCheckpointer
• checkpoint::unaligned::UnalignedSnapshot
• compiler::batch_reader::BatchRowReader
• compiler::breaker_executor::BreakerExecutor
• compiler::breaker_executor::CompiledQueryGraph
• compiler::bridge::RowBatchBridge
• compiler::cache::CompilerCache
• compiler::compilation_metrics::CacheSnapshot
• compiler::compilation_metrics::CompilationMetrics
• compiler::compilation_metrics::MetricsSnapshot
• compiler::event_time::EventTimeConfig
• compiler::event_time::RowEventTimeExtractor
• compiler::expr::ExprCompiler
• compiler::extractor::ExtractedPlan
• compiler::extractor::PipelineExtractor
• compiler::jit::JitContext
• compiler::metrics::QueryConfig
• compiler::metrics::QueryId
• compiler::metrics::QueryMetadata
• compiler::metrics::QueryMetrics
• compiler::orchestrate::CompiledStreamingQuery
• compiler::pipeline::CompiledPipeline
• compiler::pipeline::Pipeline
• compiler::pipeline::PipelineId
• compiler::pipeline::PipelineStats
• compiler::pipeline_bridge::BridgeConsumer
• compiler::pipeline_bridge::BridgeStats
• compiler::pipeline_bridge::BridgeStatsSnapshot
• compiler::pipeline_bridge::PipelineBridge
• compiler::pipeline_compiler::PipelineCompiler
• compiler::policy::BatchPolicy
• compiler::query::StreamingQuery
• compiler::query::StreamingQueryBuilder
• compiler::row::EventRow
• compiler::row::FieldLayout
• compiler::row::MutableEventRow
• compiler::row::RowSchema
• dag::builder::DagBuilder
• dag::builder::FanOutBuilder
• dag::changelog::DagChangelogPropagator
• dag::checkpoint::BarrierAligner
• dag::checkpoint::CheckpointBarrier
• dag::checkpoint::DagCheckpointConfig
• dag::checkpoint::DagCheckpointCoordinator
• dag::executor::DagExecutor
• dag::executor::DagExecutorMetrics
• dag::executor::OperatorNodeMetrics
• dag::multicast::MulticastBuffer
• dag::recovery::DagCheckpointSnapshot
• dag::recovery::DagRecoveryManager
• dag::recovery::RecoveredDagState
• dag::recovery::SerializableOperatorState
• dag::routing::RoutingEntry
• dag::routing::RoutingTable
• dag::topology::DagEdge
• dag::topology::DagNode
• dag::topology::EdgeId
• dag::topology::NodeId
• dag::topology::SharedStageMetadata
• dag::topology::StatePartitionId
• dag::topology::StreamingDag
• dag::watermark::DagWatermarkCheckpoint
• dag::watermark::DagWatermarkTracker
• delta::coordination::orchestrator::DeltaManager
• delta::discovery::ArchivedNodeId
• delta::discovery::ArchivedNodeInfo
• delta::discovery::ArchivedNodeMetadata
• delta::discovery::GossipDiscovery
• delta::discovery::GossipDiscoveryConfig
• delta::discovery::NodeId
• delta::discovery::NodeIdResolver
• delta::discovery::NodeInfo
• delta::discovery::NodeInfoResolver
• delta::discovery::NodeMetadata
• delta::discovery::NodeMetadataResolver
• delta::discovery::StaticDiscovery
• delta::discovery::StaticDiscoveryConfig
• delta::partition::assignment::AssignmentConstraints
• delta::partition::assignment::AssignmentPlan
• delta::partition::assignment::AssignmentStats
• delta::partition::assignment::ConsistentHashAssigner
• delta::partition::assignment::PartitionMove
• delta::partition::guard::ConditionalPut
• delta::partition::guard::PartitionGuard
• delta::partition::guard::PartitionGuardSet
• detect::CpuFeatures
• detect::IoUringCapabilities
• detect::KernelVersion
• detect::MemoryInfo
• detect::RecommendedConfig
• detect::StorageInfo
• detect::SystemCapabilities
• detect::XdpCapabilities
• io_uring::Completion
• io_uring::CoreRingManager
• io_uring::IoUringConfig
• io_uring::IoUringConfigBuilder
• io_uring::IoUringRing
• io_uring::RegisteredBufferPool
• io_uring::RingMetrics
• lookup::foyer_cache::FoyerMemoryCache
• lookup::foyer_cache::FoyerMemoryCacheConfig
• lookup::foyer_cache::LookupCacheKey
• lookup::predicate::SourceCapabilities
• lookup::predicate::SplitPredicates
• lookup::source::LookupSourceCapabilities
• lookup::source::PushdownAdapter
• lookup::table::LookupTableConfig
• mv::MaterializedView
• mv::MvRegistry
• numa::NumaTopology
• operator::CheckpointCompleteData
• operator::Event
• operator::OperatorContext
• operator::OperatorState
• operator::SideOutputData
• operator::Timer
• operator::asof_join::AsofJoinConfig
• operator::asof_join::AsofJoinConfigBuilder
• operator::asof_join::AsofJoinMetrics
• operator::asof_join::AsofJoinOperator
• operator::asof_join::AsofRow
• operator::asof_join::KeyState
• operator::changelog::ArchivedRetractableAvgAccumulator
• operator::changelog::ArchivedRetractableCountAccumulator
• operator::changelog::ArchivedRetractableSumAccumulator
• operator::changelog::CdcEnvelope
• operator::changelog::CdcSource
• operator::changelog::ChangelogBuffer
• operator::changelog::ChangelogRef
• operator::changelog::LateDataRetractionGenerator
• operator::changelog::RetractableAvgAccumulator
• operator::changelog::RetractableAvgAccumulatorResolver
• operator::changelog::RetractableCountAccumulator
• operator::changelog::RetractableCountAccumulatorResolver
• operator::changelog::RetractableFirstValueAccumulator
• operator::changelog::RetractableFirstValueF64Accumulator
• operator::changelog::RetractableLastValueAccumulator
• operator::changelog::RetractableLastValueF64Accumulator
• operator::changelog::RetractableMaxAccumulator
• operator::changelog::RetractableMinAccumulator
• operator::changelog::RetractableSumAccumulator
• operator::changelog::RetractableSumAccumulatorResolver
• operator::lag_lead::LagLeadConfig
• operator::lag_lead::LagLeadFunctionSpec
• operator::lag_lead::LagLeadMetrics
• operator::lag_lead::LagLeadOperator
• operator::partitioned_topk::PartitionColumn
• operator::partitioned_topk::PartitionedTopKOperator
• operator::session_window::ArchivedSessionId
• operator::session_window::ArchivedSessionIndex
• operator::session_window::ArchivedSessionMetadata
• operator::session_window::SessionId
• operator::session_window::SessionIdResolver
• operator::session_window::SessionIndex
• operator::session_window::SessionIndexResolver
• operator::session_window::SessionMetadata
• operator::session_window::SessionMetadataResolver
• operator::session_window::SessionMetrics
• operator::session_window::SessionWindowOperator
• operator::sliding_window::SlidingWindowAssigner
• operator::sliding_window::SlidingWindowOperator
• operator::stream_join::ArchivedJoinRow
• operator::stream_join::JoinMetrics
• operator::stream_join::JoinRow
• operator::stream_join::JoinRowResolver
• operator::stream_join::KeyMetadata
• operator::stream_join::SideStats
• operator::stream_join::StreamJoinConfig
• operator::stream_join::StreamJoinConfigBuilder
• operator::stream_join::StreamJoinOperator
• operator::table_cache::TableCacheMetrics
• operator::table_cache::TableLruCache
• operator::table_cache::TableXorFilter
• operator::temporal_join::ArchivedJoinedEventRecord
• operator::temporal_join::ArchivedTableRow
• operator::temporal_join::JoinedEventRecord
• operator::temporal_join::JoinedEventRecordResolver
• operator::temporal_join::TableRow
• operator::temporal_join::TableRowResolver
• operator::temporal_join::TemporalJoinConfig
• operator::temporal_join::TemporalJoinConfigBuilder
• operator::temporal_join::TemporalJoinMetrics
• operator::temporal_join::TemporalJoinOperator
• operator::temporal_join::VersionedKeyState
• operator::topk::StreamingTopKOperator
• operator::topk::TopKSortColumn
• operator::watermark_sort::WatermarkBoundedSortOperator
• operator::window::ArchivedAvgAccumulator
• operator::window::ArchivedCountAccumulator
• operator::window::ArchivedFirstValueAccumulator
• operator::window::ArchivedFirstValueF64Accumulator
• operator::window::ArchivedLastValueAccumulator
• operator::window::ArchivedLastValueF64Accumulator
• operator::window::ArchivedMaxAccumulator
• operator::window::ArchivedMinAccumulator
• operator::window::ArchivedSumAccumulator
• operator::window::ArchivedWindowId
• operator::window::AvgAccumulator
• operator::window::AvgAccumulatorResolver
• operator::window::AvgAggregator
• operator::window::AvgF64Factory
• operator::window::AvgF64IndexedAccumulator
• operator::window::ChangelogRecord
• operator::window::CompositeAccumulator
• operator::window::CompositeAggregator
• operator::window::CountAccumulator
• operator::window::CountAccumulatorResolver
• operator::window::CountAggregator
• operator::window::CountDynAccumulator
• operator::window::CountDynFactory
• operator::window::FirstValueAccumulator
• operator::window::FirstValueAccumulatorResolver
• operator::window::FirstValueAggregator
• operator::window::FirstValueF64Accumulator
• operator::window::FirstValueF64AccumulatorResolver
• operator::window::FirstValueF64Aggregator
• operator::window::FirstValueF64DynAccumulator
• operator::window::FirstValueF64DynFactory
• operator::window::LastValueAccumulator
• operator::window::LastValueAccumulatorResolver
• operator::window::LastValueAggregator
• operator::window::LastValueF64Accumulator
• operator::window::LastValueF64AccumulatorResolver
• operator::window::LastValueF64Aggregator
• operator::window::LastValueF64DynAccumulator
• operator::window::LastValueF64DynFactory
• operator::window::LateDataConfig
• operator::window::LateDataMetrics
• operator::window::MaxAccumulator
• operator::window::MaxAccumulatorResolver
• operator::window::MaxAggregator
• operator::window::MaxF64Factory
• operator::window::MaxF64IndexedAccumulator
• operator::window::MinAccumulator
• operator::window::MinAccumulatorResolver
• operator::window::MinAggregator
• operator::window::MinF64Factory
• operator::window::MinF64IndexedAccumulator
• operator::window::SumAccumulator
• operator::window::SumAccumulatorResolver
• operator::window::SumAggregator
• operator::window::SumF64Accumulator
• operator::window::SumF64Aggregator
• operator::window::SumF64Factory
• operator::window::SumF64IndexedAccumulator
• operator::window::TumblingWindowAssigner
• operator::window::TumblingWindowOperator
• operator::window::WindowCloseMetrics
• operator::window::WindowId
• operator::window::WindowIdResolver
• operator::window_sort::WindowLocalSortOperator
• reactor::Reactor
• reactor::ReactorConfig
• state::ArchivedStateSnapshot
• state::InMemoryStore
• state::MmapStateStore
• state::StateSnapshot
• state::StateSnapshotResolver
• state::ahash_store::AHashMapStore
• state::dict_encoder::DictionaryKeyEncoder
• storage_io::IoCompletion
• storage_io::IoFd
• storage_io::SyncStorageIo
• storage_io::UringStorageIo
• streaming::broadcast::BroadcastChannel
• streaming::broadcast::BroadcastConfig
• streaming::broadcast::BroadcastConfigBuilder
• streaming::broadcast::SubscriberInfo
• streaming::channel::Consumer
• streaming::channel::Producer
• streaming::checkpoint::StreamChangelogBuffer
• streaming::checkpoint::StreamChangelogEntry
• streaming::checkpoint::StreamCheckpoint
• streaming::checkpoint::StreamCheckpointConfig
• streaming::checkpoint::StreamCheckpointManager
• streaming::config::ChannelConfig
• streaming::config::ChannelConfigBuilder
• streaming::config::ChannelStats
• streaming::config::SinkConfig
• streaming::config::SourceConfig
• streaming::error::TryPushError
• streaming::ring_buffer::RingBuffer
• streaming::sink::Sink
• streaming::source::Source
• streaming::subscription::Subscription
• subscription::BackpressureController
• subscription::BatchConfig
• subscription::CallbackSubscriptionHandle
• subscription::ChangeEventBatch
• subscription::ChangeEventResultStream
• subscription::ChangeEventStream
• subscription::DemandBackpressure
• subscription::DemandHandle
• subscription::DispatcherConfig
• subscription::DispatcherMetrics
• subscription::NotificationBatcher
• subscription::NotificationHub
• subscription::NotificationRef
• subscription::NotificationRing
• subscription::NotificationSlot
• subscription::PushSubscription
• subscription::StringInternTable
• subscription::SubscriptionConfig
• subscription::SubscriptionDispatcher
• subscription::SubscriptionEntry
• subscription::SubscriptionFilter
• subscription::SubscriptionId
• subscription::SubscriptionMetrics
• subscription::SubscriptionRegistry
• time::AlignmentGroupConfig
• time::AlignmentGroupCoordinator
• time::AlignmentGroupId
• time::AlignmentGroupMetrics
• time::AlignmentSourceState
• time::AscendingTimestampsGenerator
• time::BoundedOutOfOrdernessGenerator
• time::CoreWatermarkState
• time::EventTimeExtractor
• time::GlobalWatermarkCollector
• time::KeyWatermarkState
• time::KeyedWatermarkConfig
• time::KeyedWatermarkMetrics
• time::KeyedWatermarkTracker
• time::KeyedWatermarkTrackerWithLateHandling
• time::MeteredGenerator
• time::PartitionId
• time::PartitionWatermarkState
• time::PartitionedWatermarkMetrics
• time::PartitionedWatermarkTracker
• time::PeriodicGenerator
• time::ProcessingTimeGenerator
• time::PunctuatedGenerator
• time::SourceProvidedGenerator
• time::TimerRegistration
• time::TimerService
• time::Watermark
• time::WatermarkAlignmentGroup
• time::WatermarkMetrics
• time::WatermarkTracker
• tpc::BackpressureConfig
• tpc::BackpressureConfigBuilder
• tpc::CachePadded
• tpc::CoreConfig
• tpc::CoreHandle
• tpc::CreditGate
• tpc::CreditMetrics
• tpc::CreditMetricsSnapshot
• tpc::OutputBuffer
• tpc::PartitionedRouter
• tpc::SpscQueue
• tpc::TaggedOutput
• tpc::TpcConfig
• tpc::TpcConfigBuilder

Enums

• Error
• aggregation::gossip_aggregates::AggregateScope
• aggregation::gossip_aggregates::AggregateState
• aggregation::gossip_aggregates::WatermarkGateStatus
• aggregation::two_phase::PartialState
• aggregation::two_phase::TwoPhaseError
• aggregation::two_phase::TwoPhaseKind
• budget::YieldReason
• checkpoint::barrier::StreamMessage
• checkpoint::unaligned::UnalignedAction
• compiler::bridge::BridgeError
• compiler::error::CompileError
• compiler::error::CompiledExpr
• compiler::error::ExtractError
• compiler::error::MaybeCompiledExpr
• compiler::fallback::ExecutablePipeline
• compiler::metrics::QueryError
• compiler::metrics::QueryState
• compiler::metrics::StateStoreConfig
• compiler::metrics::SubmitResult
• compiler::pipeline::PipelineAction
• compiler::pipeline::PipelineBreaker
• compiler::pipeline::PipelineStage
• compiler::pipeline_bridge::BridgeMessage
• compiler::pipeline_bridge::PipelineBridgeError
• compiler::pipeline_bridge::Ring1Action
• compiler::policy::BackpressureStrategy
• compiler::row::FieldType
• compiler::row::RowError
• dag::checkpoint::AlignmentResult
• dag::checkpoint::BarrierType
• dag::error::DagError
• dag::topology::DagChannelType
• dag::topology::DagNodeType
• dag::topology::PartitioningStrategy
• delta::coordination::orchestrator::NodeLifecyclePhase
• delta::discovery::ArchivedNodeState
• delta::discovery::DiscoveryError
• delta::discovery::MembershipEvent
• delta::discovery::NodeState
• delta::discovery::NodeStateResolver
• delta::partition::guard::EpochError
• detect::PerformanceTier
• detect::Platform
• detect::SimdLevel
• detect::StorageType
• error_codes::HotPathError
• io_uring::CompletionKind
• io_uring::IoUringError
• io_uring::PendingOp
• io_uring::RingMode
• lookup::predicate::Predicate
• lookup::predicate::ScalarValue
• lookup::source::LookupError
• lookup::table::LookupResult
• lookup::table::LookupStrategy
• mv::MvError
• mv::MvState
• numa::NumaError
• operator::OperatorError
• operator::Output
• operator::asof_join::AsofDirection
• operator::asof_join::AsofJoinType
• operator::lag_lead::AnalyticFunctionKind
• operator::stream_join::JoinRowEncoding
• operator::stream_join::JoinSide
• operator::stream_join::JoinType
• operator::table_cache::LookupDecision
• operator::temporal_join::TableChange
• operator::temporal_join::TableCharacteristics
• operator::temporal_join::TemporalJoinSemantics
• operator::temporal_join::TemporalJoinType
• operator::topk::TopKEmitStrategy
• operator::window::ArchivedCdcOperation
• operator::window::CdcOperation
• operator::window::CdcOperationResolver
• operator::window::EmitStrategy
• operator::window::ScalarResult
• reactor::ReactorError
• reactor::SinkError
• state::StateError
• storage_io::StorageIoError
• streaming::broadcast::BroadcastError
• streaming::broadcast::SlowSubscriberPolicy
• streaming::channel::ChannelMode
• streaming::checkpoint::CheckpointError
• streaming::checkpoint::OverflowPolicy
• streaming::checkpoint::StreamChangeOp
• streaming::checkpoint::WalMode
• streaming::config::BackpressureStrategy
• streaming::config::WaitStrategy
• streaming::error::RecvError
• streaming::error::StreamingError
• streaming::sink::SinkMode
• streaming::subscription::SubscriptionMessage
• subscription::BackpressureStrategy
• subscription::ChangeEvent
• subscription::EventType
• subscription::FilterCompileError
• subscription::PushSubscriptionError
• subscription::Ring0Predicate
• subscription::Ring1Predicate
• subscription::ScalarValue
• subscription::SubscriptionState
• time::AlignmentAction
• time::AlignmentError
• time::EnforcementMode
• time::EventTimeError
• time::ExtractionMode
• time::KeyEvictionPolicy
• time::KeyedWatermarkError
• time::TimeError
• time::TimestampField
• time::TimestampFormat
• time::WatermarkError
• tpc::CoreMessage
• tpc::CreditAcquireResult
• tpc::KeySpec
• tpc::OverflowStrategy
• tpc::RouterError
• tpc::TpcError

Traits

• compiler::breaker_executor::Ring1Operator
• delta::discovery::Discovery
• delta::partition::assignment::PartitionAssigner
• lookup::source::LookupSource
• lookup::source::LookupSourceDyn
• lookup::table::LookupTable
• operator::Operator
• operator::changelog::RetractableAccumulator
• operator::window::Accumulator
• operator::window::Aggregator
• operator::window::DynAccumulator
• operator::window::DynAggregatorFactory
• operator::window::ResultToArrow
• operator::window::ResultToI64
• operator::window::WindowAssigner
• reactor::Sink
• state::StateStore
• state::StateStoreExt
• storage_io::StorageIo
• streaming::source::Record
• subscription::NotificationDataSource
• subscription::SubscriptionCallback
• time::WatermarkGenerator

Macros

• hot_path

Functions

• aggregation::gossip_aggregates::check_watermark_gate
• aggregation::gossip_aggregates::merge_cluster_aggregates
• aggregation::two_phase::can_use_two_phase
• aggregation::two_phase::collect_partials
• aggregation::two_phase::decode_batch_from_ipc
• aggregation::two_phase::deserialize_partials
• aggregation::two_phase::encode_batch_to_ipc
• aggregation::two_phase::publish_partials
• aggregation::two_phase::serialize_partials
• alloc::is_hot_path_enabled
• alloc::set_panic_on_alloc
• compiler::fold::fold_constants
• compiler::orchestrate::compile_streaming_query
• compiler::pipeline_bridge::create_pipeline_bridge
• detect::cache_line_size
• detect::is_smt_enabled
• detect::logical_cpu_count
• detect::physical_cpu_count
• io_uring::advanced_kernel_version
• io_uring::is_available
• io_uring::min_kernel_version
• lookup::predicate::predicate_to_sql
• lookup::predicate::split_predicates
• operator::table_cache::collect_cache_metrics
• operator::topk::encode_f64
• operator::topk::encode_i64
• operator::topk::encode_not_null
• operator::topk::encode_null
• operator::topk::encode_utf8
• serialization::deserialize_batch_stream
• serialization::serialize_batch_stream
• streaming::channel::channel
• streaming::channel::channel_with_config
• streaming::source::create
• streaming::source::create_with_config
• subscription::compile_filter
• subscription::subscribe_callback
• subscription::subscribe_fn
• subscription::subscribe_stream
• subscription::subscribe_stream_with_errors

Type Aliases

• Result
• compiler::error::FilterFn
• compiler::error::ScalarFn
• compiler::pipeline::PipelineFn
• dag::checkpoint::CheckpointId
• dag::topology::PartitionFn
• lookup::source::ColumnId
• numa::Result
• operator::OutputVec
• operator::TimerKey
• operator::window::WindowIdVec
• time::FiredTimersVec
• time::TimerKey

Constants

• checkpoint::barrier::flags::CANCEL
• checkpoint::barrier::flags::DRAIN
• checkpoint::barrier::flags::FULL_SNAPSHOT
• checkpoint::barrier::flags::NONE
• checkpoint::barrier::flags::UNALIGNED
• dag::routing::MAX_PORTS
• dag::topology::MAX_FAN_OUT
• delta::discovery::keys::FAILURE_DOMAIN
• delta::discovery::keys::LOAD_CORES
• delta::discovery::keys::LOAD_MEMORY
• delta::discovery::keys::NODE_NAME
• delta::discovery::keys::NODE_STATE
• delta::discovery::keys::NODE_VERSION
• delta::discovery::keys::PARTITIONS_OWNED
• delta::discovery::keys::RAFT_ADDRESS
• delta::discovery::keys::RPC_ADDRESS
• error_codes::ARROW_ERROR
• error_codes::BASE64_DECODE_ERROR
• error_codes::CHECKPOINT_FAILED
• error_codes::CHECKPOINT_NOT_FOUND
• error_codes::CHECKPOINT_PRUNE_FAILED
• error_codes::CONNECTOR_AUTH_FAILED
• error_codes::CONNECTOR_CONFIG_ERROR
• error_codes::CONNECTOR_CONNECTION_FAILED
• error_codes::CONNECTOR_READ_ERROR
• error_codes::CONNECTOR_SCHEMA_ERROR
• error_codes::CONNECTOR_SERDE_ERROR
• error_codes::CONNECTOR_WRITE_ERROR
• error_codes::DESERIALIZATION_FAILED
• error_codes::EXACTLY_ONCE_NON_REPLAYABLE
• error_codes::EXACTLY_ONCE_NO_CHECKPOINT
• error_codes::EXACTLY_ONCE_SINK_UNSUPPORTED
• error_codes::INTERNAL
• error_codes::INVALID_CONFIG
• error_codes::INVALID_OPERATION
• error_codes::JOIN_KEY_MISSING
• error_codes::JOIN_TIME_BOUND_MISSING
• error_codes::JOIN_TYPE_UNSUPPORTED
• error_codes::JSON_PARSE_ERROR
• error_codes::LATE_DATA_REJECTED
• error_codes::MANIFEST_PERSIST_FAILED
• error_codes::MATERIALIZED_VIEW_ERROR
• error_codes::MISSING_CONFIG
• error_codes::MIXED_DELIVERY_CAPABILITIES
• error_codes::OFFSET_METADATA_MISSING
• error_codes::PIPELINE_ERROR
• error_codes::PLAN_OPTIMIZATION_FAILED
• error_codes::QUERY_EXECUTION_FAILED
• error_codes::QUERY_PIPELINE_ERROR
• error_codes::RECOVERY_FAILED
• error_codes::SCHEMA_MISMATCH
• error_codes::SERIALIZATION_FAILED
• error_codes::SHUTDOWN
• error_codes::SIDECAR_CORRUPTION
• error_codes::SINK_ALREADY_EXISTS
• error_codes::SINK_NOT_FOUND
• error_codes::SINK_ROLLBACK_FAILED
• error_codes::SOURCE_ALREADY_EXISTS
• error_codes::SOURCE_NOT_FOUND
• error_codes::SQL_COLUMN_NOT_FOUND
• error_codes::SQL_PLANNING_FAILED
• error_codes::SQL_TABLE_NOT_FOUND
• error_codes::SQL_TYPE_MISMATCH
• error_codes::SQL_UNSUPPORTED
• error_codes::STATE_CORRUPTION
• error_codes::STATE_KEY_MISSING
• error_codes::TEMPORAL_JOIN_NO_PK
• error_codes::UNRESOLVED_CONFIG_VAR
• error_codes::WAL_CHECKSUM_MISMATCH
• error_codes::WAL_ERROR
• error_codes::WAL_INVALID_LENGTH
• error_codes::WATERMARK_REQUIRED
• error_codes::WINDOW_INVALID
• error_codes::WINDOW_SIZE_INVALID
• streaming::broadcast::DEFAULT_BROADCAST_CAPACITY
• streaming::broadcast::DEFAULT_LAG_WARNING_THRESHOLD
• streaming::broadcast::DEFAULT_MAX_SUBSCRIBERS
• streaming::broadcast::DEFAULT_SLOW_SUBSCRIBER_TIMEOUT
• streaming::config::DEFAULT_BUFFER_SIZE
• streaming::config::MAX_BUFFER_SIZE
• streaming::config::MIN_BUFFER_SIZE