List of all items

Structs

• cache::ManagedLruCache
• cache::MutGuard
• cache::managed_lru::HeapSizeReporter
• cache::managed_lru::ManagedLruCache
• cache::managed_lru::MutGuard
• common::StateTableColumnMapping
• common::column_mapping::StateTableColumnMapping
• common::compact_chunk::OpRowMutRefTuple
• common::compact_chunk::RowOpMap
• common::compact_chunk::StreamChunkCompactor
• common::log_store_impl::in_mem::BoundedInMemLogStoreFactory
• common::log_store_impl::in_mem::BoundedInMemLogStoreReader
• common::log_store_impl::in_mem::BoundedInMemLogStoreWriter
• common::log_store_impl::kv_log_store::FlushInfo
• common::log_store_impl::kv_log_store::KvLogStoreFactory
• common::log_store_impl::kv_log_store::KvLogStoreMetrics
• common::log_store_impl::kv_log_store::KvLogStorePkInfo
• common::log_store_impl::kv_log_store::KvLogStoreReadMetrics
• common::log_store_impl::kv_log_store::buffer::LogStoreBufferInner
• common::log_store_impl::kv_log_store::buffer::LogStoreBufferReceiver
• common::log_store_impl::kv_log_store::buffer::LogStoreBufferSender
• common::log_store_impl::kv_log_store::buffer::SharedMutex
• common::log_store_impl::kv_log_store::reader::AutoRebuildStateStoreReadIter
• common::log_store_impl::kv_log_store::reader::KvLogStoreReader
• common::log_store_impl::kv_log_store::reader::RewindDelay
• common::log_store_impl::kv_log_store::serde::LogStoreRowOpStream
• common::log_store_impl::kv_log_store::serde::LogStoreRowSerde
• common::log_store_impl::kv_log_store::serde::ReadInfo
• common::log_store_impl::kv_log_store::writer::KvLogStoreWriter
• common::metrics::MetricsInfo
• common::state_cache::OrderedStateCache
• common::state_cache::TopNStateCache
• common::state_cache::ordered::OrderedStateCache
• common::state_cache::top_n::TopNStateCache
• common::table::state_table::StateTableInner
• common::table::state_table_cache::StateTableWatermarkCache
• error::StreamError
• executor::Actor
• executor::ActorContext
• executor::AddMutation
• executor::AppendOnlyDedupExecutor
• executor::ArrangementBackfillExecutor
• executor::AsOfDesc
• executor::BackfillExecutor
• executor::BackfillState
• executor::BarrierInner
• executor::BarrierRecvExecutor
• executor::BatchQueryExecutor
• executor::CdcBackfillExecutor
• executor::CdcScanOptions
• executor::ChainExecutor
• executor::ChangeLogExecutor
• executor::DispatchExecutor
• executor::DummyExecutor
• executor::DynamicFilterExecutor
• executor::EowcOverWindowExecutor
• executor::EowcOverWindowExecutorArgs
• executor::Executor
• executor::ExecutorInfo
• executor::ExpandExecutor
• executor::ExternalStorageTable
• executor::FilterExecutor
• executor::GlobalApproxPercentileExecutor
• executor::HashAggExecutor
• executor::HopWindowExecutor
• executor::LocalApproxPercentileExecutor
• executor::LookupExecutor
• executor::LookupExecutorParams
• executor::LookupUnionExecutor
• executor::MaterializeBuffer
• executor::MaterializeCache
• executor::MaterializeExecutor
• executor::MergeExecutor
• executor::NestedLoopTemporalJoinExecutor
• executor::NoOpExecutor
• executor::NowExecutor
• executor::OverWindowExecutor
• executor::OverWindowExecutorArgs
• executor::ProjectExecutor
• executor::ProjectSetExecutor
• executor::RearrangedChainExecutor
• executor::ReceiverExecutor
• executor::RowMergeExecutor
• executor::SimpleAggExecutor
• executor::SinkExecutor
• executor::SnapshotBackfillExecutor
• executor::SortExecutor
• executor::SortExecutorArgs
• executor::StatelessSimpleAggExecutor
• executor::TemporalJoinExecutor
• executor::TroublemakerExecutor
• executor::UnionExecutor
• executor::UpdateMutation
• executor::ValuesExecutor
• executor::Watermark
• executor::WatermarkFilterExecutor
• executor::WrapperExecutor
• executor::actor::Actor
• executor::actor::ActorContext
• executor::agg_common::AggExecutorArgs
• executor::agg_common::HashAggExecutorExtraArgs
• executor::agg_common::SimpleAggExecutorExtraArgs
• executor::aggregation::AggGroup
• executor::aggregation::AggStateCacheStats
• executor::aggregation::AlwaysOutput
• executor::aggregation::DistinctDeduplicater
• executor::aggregation::GroupKey
• executor::aggregation::OnlyOutputIfHasInput
• executor::aggregation::agg_group::AggGroup
• executor::aggregation::agg_group::AggStateCacheStats
• executor::aggregation::agg_group::AlwaysOutput
• executor::aggregation::agg_group::GroupKey
• executor::aggregation::agg_group::OnlyOutputIfHasInput
• executor::aggregation::agg_state_cache::CacheValue
• executor::aggregation::agg_state_cache::GenericAggStateCache
• executor::aggregation::agg_state_cache::GenericAggStateCacheFiller
• executor::aggregation::distinct::ColumnDeduplicater
• executor::aggregation::distinct::DistinctDeduplicater
• executor::aggregation::minput::MaterializedInputState
• executor::approx_percentile::global::GlobalApproxPercentileExecutor
• executor::approx_percentile::global_state::BucketTableCache
• executor::approx_percentile::global_state::GlobalApproxPercentileState
• executor::approx_percentile::local::LocalApproxPercentileExecutor
• executor::asof_join::AsOfJoinExecutor
• executor::asof_join::EqJoinArgs
• executor::asof_join::JoinParams
• executor::asof_join::JoinSide
• executor::backfill::arrangement_backfill::ArrangementBackfillExecutor
• executor::backfill::cdc::CdcScanOptions
• executor::backfill::cdc::cdc_backfill::CdcBackfillExecutor
• executor::backfill::cdc::state::CdcBackfillState
• executor::backfill::cdc::state::CdcStateRecord
• executor::backfill::cdc::upstream_table::external::ExternalStorageTable
• executor::backfill::cdc::upstream_table::snapshot::SnapshotReadArgs
• executor::backfill::cdc::upstream_table::snapshot::UpstreamTableReader
• executor::backfill::no_shuffle_backfill::BackfillExecutor
• executor::backfill::no_shuffle_backfill::BackfillState
• executor::backfill::snapshot_backfill::ConsumingLogStore
• executor::backfill::snapshot_backfill::ConsumingSnapshot
• executor::backfill::snapshot_backfill::SnapshotBackfillExecutor
• executor::backfill::snapshot_backfill::UpstreamBuffer
• executor::backfill::utils::BackfillState
• executor::backfill::utils::BackfillStatePerVnode
• executor::barrier_recv::BarrierRecvExecutor
• executor::batch_query::BatchQueryExecutor
• executor::chain::ChainExecutor
• executor::changelog::ChangeLogExecutor
• executor::dedup::append_only_dedup::AppendOnlyDedupExecutor
• executor::dedup::cache::DedupCache
• executor::dispatch::BroadcastDispatcher
• executor::dispatch::DispatchExecutor
• executor::dispatch::DispatchExecutorInner
• executor::dispatch::DispatchExecutorMetrics
• executor::dispatch::DispatcherWithMetrics
• executor::dispatch::HashDataDispatcher
• executor::dispatch::RoundRobinDataDispatcher
• executor::dispatch::SimpleDispatcher
• executor::dml::DmlExecutor
• executor::dml::TxnBuffer
• executor::dynamic_filter::DynamicFilterExecutor
• executor::error::StreamExecutorError
• executor::exchange::error::ExchangeChannelClosed
• executor::exchange::input::LocalInput
• executor::exchange::input::RemoteInput
• executor::exchange::output::LocalOutput
• executor::exchange::output::RemoteOutput
• executor::exchange::permit::MessageWithPermits
• executor::exchange::permit::Permits
• executor::exchange::permit::Receiver
• executor::exchange::permit::Sender
• executor::expand::ExpandExecutor
• executor::filter::FilterExecutor
• executor::hash_agg::ExecutionStats
• executor::hash_agg::ExecutionVars
• executor::hash_agg::ExecutorInner
• executor::hash_agg::HashAggExecutor
• executor::hash_join::EqJoinArgs
• executor::hash_join::HashJoinExecutor
• executor::hash_join::JoinParams
• executor::hash_join::JoinSide
• executor::hop_window::HopWindowExecutor
• executor::join::AsOfDesc
• executor::join::builder::JoinChunkBuilder
• executor::join::builder::JoinStreamChunkBuilder
• executor::join::hash_join::HashValueWrapper
• executor::join::hash_join::InequalityKeyDesc
• executor::join::hash_join::JoinEntryState
• executor::join::hash_join::JoinHashMap
• executor::join::hash_join::JoinHashMapMetrics
• executor::join::hash_join::TableInner
• executor::join::join_row_set::VecOccupiedError
• executor::join::row::EncodedJoinRow
• executor::join::row::JoinRow
• executor::lookup::LookupExecutor
• executor::lookup::cache::LookupCache
• executor::lookup::impl_::LookupExecutorParams
• executor::lookup::sides::ArrangeJoinSide
• executor::lookup::sides::StreamJoinSide
• executor::lookup_union::LookupUnionExecutor
• executor::merge::BufferChunks
• executor::merge::MergeExecutor
• executor::merge::MergeExecutorInput
• executor::merge::SelectReceivers
• executor::monitor::streaming_stats::ActorInputMetrics
• executor::monitor::streaming_stats::ActorMetrics
• executor::monitor::streaming_stats::AggDistinctDedupMetrics
• executor::monitor::streaming_stats::BackfillMetrics
• executor::monitor::streaming_stats::CdcBackfillMetrics
• executor::monitor::streaming_stats::GroupTopNMetrics
• executor::monitor::streaming_stats::HashAggMetrics
• executor::monitor::streaming_stats::LookupExecutorMetrics
• executor::monitor::streaming_stats::MaterializeMetrics
• executor::monitor::streaming_stats::OverWindowMetrics
• executor::monitor::streaming_stats::SinkExecutorMetrics
• executor::monitor::streaming_stats::StreamingMetrics
• executor::monitor::streaming_stats::TemporalJoinMetrics
• executor::mview::materialize::MaterializeBuffer
• executor::mview::materialize::MaterializeCache
• executor::mview::materialize::MaterializeExecutor
• executor::nested_loop_temporal_join::NestedLoopTemporalJoinExecutor
• executor::nested_loop_temporal_join::TemporalSide
• executor::no_op::NoOpExecutor
• executor::now::NowExecutor
• executor::over_window::eowc::EowcOverWindowExecutor
• executor::over_window::eowc::EowcOverWindowExecutorArgs
• executor::over_window::eowc::ExecutionVars
• executor::over_window::eowc::ExecutorInner
• executor::over_window::eowc::Partition
• executor::over_window::general::Calls
• executor::over_window::general::ExecutionStats
• executor::over_window::general::ExecutionVars
• executor::over_window::general::ExecutorInner
• executor::over_window::general::OverWindowExecutor
• executor::over_window::general::OverWindowExecutorArgs
• executor::over_window::general::RowConverter
• executor::over_window::over_partition::AffectedRange
• executor::over_window::over_partition::OverPartition
• executor::over_window::over_partition::OverPartitionStats
• executor::prelude::Arc
• executor::prelude::Formatter
• executor::prelude::OwnedRow
• executor::prelude::RowRef
• executor::prelude::Schema
• executor::prelude::StreamChunk
• executor::prelude::StreamChunkBuilder
• executor::project::Inner
• executor::project::ProjectExecutor
• executor::project_set::Inner
• executor::project_set::ProjectSetExecutor
• executor::rearranged_chain::RearrangedChainExecutor
• executor::receiver::ReceiverExecutor
• executor::row_id_gen::RowIdGenExecutor
• executor::row_merge::RowMergeExecutor
• executor::simple_agg::ExecutionVars
• executor::simple_agg::ExecutorInner
• executor::simple_agg::SimpleAggExecutor
• executor::sink::SinkExecutor
• executor::sort::ExecutionVars
• executor::sort::ExecutorInner
• executor::sort::SortExecutor
• executor::sort::SortExecutorArgs
• executor::sort_buffer::SortBuffer
• executor::source::BackfillStateTableHandler
• executor::source::BackfillStateWithProgress
• executor::source::FsFetchExecutor
• executor::source::FsListExecutor
• executor::source::FsSourceExecutor
• executor::source::SourceBackfillExecutor
• executor::source::SourceBackfillExecutorInner
• executor::source::SourceExecutor
• executor::source::StreamSourceCore
• executor::source::executor_core::StreamSourceCore
• executor::source::fetch_executor::FsFetchExecutor
• executor::source::fs_source_executor::FsSourceExecutor
• executor::source::list_executor::FsListExecutor
• executor::source::source_backfill_executor::BackfillStage
• executor::source::source_backfill_executor::BackfillStateWithProgress
• executor::source::source_backfill_executor::SourceBackfillExecutor
• executor::source::source_backfill_executor::SourceBackfillExecutorInner
• executor::source::source_backfill_state_table::BackfillStateTableHandler
• executor::source::source_executor::SourceExecutor
• executor::source::source_executor::WaitCheckpointTaskBuilder
• executor::source::source_executor::WaitCheckpointWorker
• executor::source::state_table_handler::SourceStateTableHandler
• executor::stateless_simple_agg::StatelessSimpleAggExecutor
• executor::stream_reader::StreamReaderWithPause
• executor::subtask::SubtaskRxExecutor
• executor::temporal_join::JoinEntry
• executor::temporal_join::TemporalJoinExecutor
• executor::temporal_join::TemporalSide
• executor::temporal_join::phase1::Inner
• executor::temporal_join::phase1::LeftOuter
• executor::temporal_join::phase1::LeftOuterWithCond
• executor::test_utils::MessageSender
• executor::test_utils::MockSource
• executor::test_utils::prelude::Arc
• executor::test_utils::prelude::AtomicU64
• executor::test_utils::prelude::ColumnDesc
• executor::test_utils::prelude::ColumnId
• executor::test_utils::prelude::Field
• executor::test_utils::prelude::OrderType
• executor::test_utils::prelude::Schema
• executor::test_utils::prelude::StreamChunk
• executor::test_utils::prelude::TableId
• executor::top_n::group_top_n::GroupTopNCache
• executor::top_n::group_top_n::InnerGroupTopNExecutor
• executor::top_n::group_top_n_appendonly::InnerAppendOnlyGroupTopNExecutor
• executor::top_n::top_n_appendonly::InnerAppendOnlyTopNExecutor
• executor::top_n::top_n_cache::TopNCache
• executor::top_n::top_n_cache::TopNStaging
• executor::top_n::top_n_plain::InnerTopNExecutor
• executor::top_n::top_n_state::ManagedTopNState
• executor::top_n::top_n_state::TopNStateRow
• executor::top_n::utils::TopNExecutorWrapper
• executor::troublemaker::Inner
• executor::troublemaker::TroublemakerExecutor
• executor::troublemaker::Vars
• executor::union::Input
• executor::union::UnionExecutor
• executor::utils::DummyExecutor
• executor::values::ValuesExecutor
• executor::watermark::BufferedWatermarks
• executor::watermark::StagedWatermarks
• executor::watermark_filter::WatermarkFilterExecutor
• executor::wrapper::WrapperExecutor
• from_proto::append_only_dedup::AppendOnlyDedupExecutorBuilder
• from_proto::approx_percentile::global::GlobalApproxPercentileExecutorBuilder
• from_proto::approx_percentile::local::LocalApproxPercentileExecutorBuilder
• from_proto::asof_join::AsOfJoinExecutorBuilder
• from_proto::asof_join::AsOfJoinExecutorDispatcherArgs
• from_proto::barrier_recv::BarrierRecvExecutorBuilder
• from_proto::batch_query::BatchQueryExecutorBuilder
• from_proto::cdc_filter::CdcFilterExecutorBuilder
• from_proto::changelog::ChangeLogExecutorBuilder
• from_proto::dml::DmlExecutorBuilder
• from_proto::dynamic_filter::DynamicFilterExecutorBuilder
• from_proto::eowc_over_window::EowcOverWindowExecutorBuilder
• from_proto::expand::ExpandExecutorBuilder
• from_proto::filter::FilterExecutorBuilder
• from_proto::group_top_n::GroupTopNExecutorBuilder
• from_proto::group_top_n::GroupTopNExecutorDispatcherArgs
• from_proto::hash_agg::HashAggExecutorBuilder
• from_proto::hash_agg::HashAggExecutorDispatcherArgs
• from_proto::hash_join::HashJoinExecutorBuilder
• from_proto::hash_join::HashJoinExecutorDispatcherArgs
• from_proto::hop_window::HopWindowExecutorBuilder
• from_proto::lookup::LookupExecutorBuilder
• from_proto::lookup_union::LookupUnionExecutorBuilder
• from_proto::merge::MergeExecutorBuilder
• from_proto::mview::ArrangeExecutorBuilder
• from_proto::mview::MaterializeExecutorBuilder
• from_proto::no_op::NoOpExecutorBuilder
• from_proto::now::NowExecutorBuilder
• from_proto::over_window::OverWindowExecutorBuilder
• from_proto::project::ProjectExecutorBuilder
• from_proto::project_set::ProjectSetExecutorBuilder
• from_proto::row_id_gen::RowIdGenExecutorBuilder
• from_proto::row_merge::RowMergeExecutorBuilder
• from_proto::simple_agg::SimpleAggExecutorBuilder
• from_proto::sink::SinkExecutorBuilder
• from_proto::sort::SortExecutorBuilder
• from_proto::source::fs_fetch::FsFetchExecutorBuilder
• from_proto::source::trad_source::SourceExecutorBuilder
• from_proto::source_backfill::SourceBackfillExecutorBuilder
• from_proto::stateless_simple_agg::StatelessSimpleAggExecutorBuilder
• from_proto::stream_cdc_scan::StreamCdcScanExecutorBuilder
• from_proto::stream_scan::StreamScanExecutorBuilder
• from_proto::temporal_join::NestedLoopTemporalJoinExecutorDispatcherArgs
• from_proto::temporal_join::TemporalJoinExecutorBuilder
• from_proto::temporal_join::TemporalJoinExecutorDispatcherArgs
• from_proto::top_n::TopNExecutorBuilder
• from_proto::union::UnionExecutorBuilder
• from_proto::values::ValuesExecutorBuilder
• from_proto::watermark_filter::WatermarkFilterBuilder
• task::ActorEvalErrorReport
• task::BarrierCompleteResult
• task::CreateMviewProgressReporter
• task::ExecutorParams
• task::LocalBarrierManager
• task::LocalStreamManager
• task::PartialGraphId
• task::SharedContext
• task::StreamEnvironment
• task::await_tree_key::Actor
• task::await_tree_key::BarrierAwait
• task::barrier_manager::BarrierCompleteResult
• task::barrier_manager::ControlStreamHandle
• task::barrier_manager::EventSender
• task::barrier_manager::LocalBarrierManager
• task::barrier_manager::LocalBarrierWorker
• task::barrier_manager::LocalBarrierWorkerDebugInfo
• task::barrier_manager::ScoredStreamError
• task::barrier_manager::StreamActorManager
• task::barrier_manager::managed_state::BarrierState
• task::barrier_manager::managed_state::InflightActorState
• task::barrier_manager::managed_state::IssuedState
• task::barrier_manager::managed_state::ManagedBarrierState
• task::barrier_manager::managed_state::ManagedBarrierStateDebugInfo
• task::barrier_manager::managed_state::PartialGraphManagedBarrierState
• task::barrier_manager::progress::CreateMviewProgressReporter
• task::env::StreamEnvironment
• task::stream_manager::ActorEvalErrorReport
• task::stream_manager::ExecutorParams
• task::stream_manager::LocalStreamManager
• task::stream_manager::await_tree_key::Actor
• task::stream_manager::await_tree_key::BarrierAwait

Enums

• common::compact_chunk::RowOp
• common::log_store_impl::in_mem::InMemLogStoreItem
• common::log_store_impl::in_mem::LogReaderEpochProgress
• common::log_store_impl::kv_log_store::buffer::LogStoreBufferItem
• common::log_store_impl::kv_log_store::serde::KvLogStoreItem
• common::log_store_impl::kv_log_store::serde::LogStoreOp
• common::log_store_impl::kv_log_store::serde::LogStoreRowOp
• common::log_store_impl::kv_log_store::serde::StreamState
• common::table::state_table::StateTableOpConsistencyLevel
• error::ErrorKind
• executor::DispatcherImpl
• executor::MessageInner
• executor::Mutation
• executor::NowMode
• executor::ProjectSetSelectItem
• executor::aggregation::AggState
• executor::aggregation::AggStateStorage
• executor::aggregation::agg_state::AggState
• executor::aggregation::agg_state::AggStateStorage
• executor::backfill::utils::BackfillProgressPerVnode
• executor::barrier_align::AlignedMessage
• executor::dispatch::DispatcherImpl
• executor::error::ErrorKind
• executor::join::AsOfInequalityType
• executor::join::hash_join::JoinEntryError
• executor::join::join_row_set::JoinRowSet
• executor::join::join_row_set::JoinRowSetOccupiedError
• executor::lookup::sides::ArrangeMessage
• executor::merge::MergeExecutorUpstream
• executor::now::ModeVars
• executor::now::NowMode
• executor::prelude::DataType
• executor::prelude::ScalarImpl
• executor::prelude::ScalarRefImpl
• executor::project_set::ProjectSetSelectItem
• executor::rearranged_chain::RearrangedMessage
• executor::source::BackfillState
• executor::source::source_backfill_executor::BackfillState
• executor::temporal_join::InternalMessage
• executor::test_utils::prelude::DataType
• task::barrier_manager::LocalActorOperation
• task::barrier_manager::LocalBarrierEvent
• task::barrier_manager::managed_state::InflightActorStatus
• task::barrier_manager::managed_state::ManagedBarrierStateInner
• task::barrier_manager::progress::BackfillState

Traits

• common::state_cache::StateCache
• common::state_cache::StateCacheFiller
• common::table::state_table::KeyedRowStream
• error::IntoUnexpectedExit
• executor::Execute
• executor::StreamConsumer
• executor::agg_common::AggExecutorExtraArgs
• executor::aggregation::Strategy
• executor::aggregation::agg_group::Strategy
• executor::aggregation::agg_state_cache::AggStateCache
• executor::aggregation::agg_state_cache::AggStateCacheFiller
• executor::backfill::cdc::upstream_table::snapshot::UpstreamTableRead
• executor::dispatch::Dispatcher
• executor::exchange::input::Input
• executor::exchange::output::Output
• executor::prelude::Debug
• executor::prelude::InstrumentAwait
• executor::prelude::Row
• executor::prelude::StateStore
• executor::prelude::Stream
• executor::prelude::StreamExt
• executor::temporal_join::phase1::Phase1Evaluation
• executor::test_utils::StreamExecutorTestExt
• executor::test_utils::prelude::StateStore
• executor::test_utils::prelude::StreamChunkTestExt
• executor::top_n::top_n_cache::AppendOnlyTopNCacheTrait
• executor::top_n::top_n_cache::TopNCacheTrait
• executor::top_n::utils::TopNExecutorBase
• from_proto::ExecutorBuilder

Macros

• common::table::state_table::insane_mode_discard_point
• consistency::consistency_error
• consistency::consistency_panic
• executor::dispatch::for_all_dispatcher_variants
• executor::dispatch::impl_dispatcher
• executor::prelude::pin
• executor::prelude::pin_mut
• from_proto::build_executor
• row_nonnull

Attribute Macros

• executor::prelude::for_await
• executor::prelude::try_stream

Derive Macros

• executor::prelude::Debug

Functions

• cache::cache_may_stale
• common::compact_chunk::merge_chunk_row
• common::log_store_impl::kv_log_store::buffer::new_log_store_buffer
• common::log_store_impl::kv_log_store::reader::rewind_backoff_policy::initial_rewind_backoff_policy
• common::log_store_impl::kv_log_store::reader::timeout_auto_rebuild::iter_with_timeout_rebuild
• common::log_store_impl::kv_log_store::serde::merge_log_store_item_stream
• common::log_store_impl::kv_log_store::serde::stream_de::deserialize_stream
• common::log_store_impl::kv_log_store::serde::stream_de::may_merge_update
• common::rate_limit::limited_chunk_size
• common::table::state_table::consistent_old_value_op
• common::table::state_table::deserialize_keyed_row_stream
• common::table::state_table::end_range_to_memcomparable
• common::table::state_table::fill_non_output_indices
• common::table::state_table::prefix_and_sub_range_to_memcomparable
• common::table::state_table::prefix_range_to_memcomparable
• common::table::state_table::start_range_to_memcomparable
• common::table::test_utils::gen_pbtable
• common::table::test_utils::gen_pbtable_inner
• common::table::test_utils::gen_pbtable_with_dist_key
• common::table::test_utils::gen_pbtable_with_value_indices
• config::chunk_size
• consistency::enable_strict_consistency
• consistency::insane
• executor::actor::spawn_blocking_drop_stream
• executor::aggregation::agg_call_filter_res
• executor::aggregation::distinct::get_many_mut_from_slice
• executor::aggregation::iter_table_storage
• executor::aggregation::minput::generate_order_columns_before_version_issue_13465
• executor::asof_join::is_subset
• executor::backfill::cdc::cdc_backfill::parse_debezium_chunk
• executor::backfill::cdc::cdc_backfill::transform_upstream
• executor::backfill::cdc::upstream_table::snapshot::with_additional_columns
• executor::backfill::snapshot_backfill::make_consume_snapshot_stream
• executor::backfill::snapshot_backfill::make_snapshot_stream
• executor::backfill::snapshot_backfill::read_change_log
• executor::backfill::snapshot_backfill::receive_next_barrier
• executor::backfill::utils::build_temporary_state
• executor::backfill::utils::compute_bounds
• executor::backfill::utils::construct_initial_finished_state
• executor::backfill::utils::create_builder
• executor::backfill::utils::create_limiter
• executor::backfill::utils::flush_data
• executor::backfill::utils::get_cdc_chunk_last_offset
• executor::backfill::utils::get_new_pos
• executor::backfill::utils::get_progress_per_vnode
• executor::backfill::utils::iter_chunks
• executor::backfill::utils::mapping_chunk
• executor::backfill::utils::mapping_message
• executor::backfill::utils::mapping_watermark
• executor::backfill::utils::mark_cdc_chunk
• executor::backfill::utils::mark_cdc_chunk_inner
• executor::backfill::utils::mark_chunk
• executor::backfill::utils::mark_chunk_inner
• executor::backfill::utils::mark_chunk_ref_by_vnode
• executor::backfill::utils::owned_row_iter
• executor::backfill::utils::persist_state
• executor::backfill::utils::persist_state_per_vnode
• executor::backfill::utils::update_pos_by_vnode
• executor::barrier_align::barrier_align
• executor::build_add_interval_expr
• executor::build_add_interval_expr_captured
• executor::curr_epoch
• executor::dispatch::broadcast_concurrent
• executor::epoch
• executor::exchange::input::apply_dispatcher_barrier
• executor::exchange::input::assert_equal_dispatcher_barrier
• executor::exchange::input::local_input::run
• executor::exchange::input::local_input::run_inner
• executor::exchange::input::new_input
• executor::exchange::input::process_dispatcher_msg
• executor::exchange::input::remote_input::run
• executor::exchange::input::remote_input::run_inner
• executor::exchange::output::new_output
• executor::exchange::permit::channel
• executor::exchange::permit::channel_for_test
• executor::expect_first_barrier
• executor::expect_first_barrier_from_aligned_stream
• executor::hash_join::is_subset
• executor::join::forward_exactly_once
• executor::join::is_anti
• executor::join::is_as_of_left_outer
• executor::join::is_left_semi_or_anti
• executor::join::is_outer_side
• executor::join::is_right_semi_or_anti
• executor::join::is_semi
• executor::join::need_left_degree
• executor::join::need_right_degree
• executor::join::only_forward_matched_side
• executor::join::outer_side_null
• executor::join::row::build_degree_row
• executor::lookup::sides::align_barrier
• executor::lookup::sides::poll_until_barrier
• executor::lookup::sides::stream_lookup_arrange_prev_epoch
• executor::lookup::sides::stream_lookup_arrange_this_epoch
• executor::monitor::streaming_stats::global_streaming_metrics
• executor::mview::materialize::execute_do_update_if_not_null_replacement
• executor::mview::materialize::generate_output
• executor::mview::materialize::get_op_consistency_level
• executor::mview::materialize::should_handle_conflict
• executor::nested_loop_temporal_join::phase1_handle_chunk
• executor::now::build_add_interval_expr
• executor::now::build_add_interval_expr_captured
• executor::over_window::frame_finder::calc_logical_boundary_for_range_frames
• executor::over_window::frame_finder::calc_logical_curr_for_range_frames
• executor::over_window::frame_finder::calc_logical_ord_for_range_frames
• executor::over_window::frame_finder::find_boundary_for_rows_frame
• executor::over_window::frame_finder::find_curr_for_rows_frame
• executor::over_window::frame_finder::find_first_curr_for_rows_frame
• executor::over_window::frame_finder::find_for_range_frames
• executor::over_window::frame_finder::find_frame_end_for_rows_frame
• executor::over_window::frame_finder::find_frame_start_for_rows_frame
• executor::over_window::frame_finder::find_last_curr_for_rows_frame
• executor::over_window::frame_finder::find_left_for_range_frames
• executor::over_window::frame_finder::find_right_for_range_frames
• executor::over_window::frame_finder::merge_rows_frames
• executor::over_window::over_partition::new_empty_partition_cache
• executor::over_window::over_partition::shrink_partition_cache
• executor::prev_epoch
• executor::sink::force_append_only
• executor::sink::force_delete_only
• executor::sort_buffer::key_value_to_full_row
• executor::sort_buffer::row_to_cache_key
• executor::source::apply_rate_limit
• executor::source::barrier_to_message_stream
• executor::source::get_split_offset_col_idx
• executor::source::get_split_offset_mapping_from_chunk
• executor::source::prune_additional_cols
• executor::source::source_backfill_executor::compare_kafka_offset
• executor::stream_reader::stream_reader_with_pause::new_inner
• executor::subtask::wrap
• executor::temporal_join::align_input
• executor::temporal_join::apply_indices_map
• executor::temporal_join::chunks_until_barrier
• executor::temporal_join::internal_messages_until_barrier
• executor::temporal_join::phase1::handle_chunk
• executor::test_utils::agg_executor::create_agg_state_storage
• executor::test_utils::agg_executor::create_intermediate_state_table
• executor::test_utils::agg_executor::generate_agg_schema
• executor::test_utils::agg_executor::new_boxed_hash_agg_executor
• executor::test_utils::agg_executor::new_boxed_simple_agg_executor
• executor::test_utils::expr::build_from_pretty
• executor::test_utils::top_n_executor::create_in_memory_state_table
• executor::test_utils::top_n_executor::create_in_memory_state_table_from_state_store
• executor::top_n::utils::create_cache_key_serde
• executor::top_n::utils::serialize_pk_to_cache_key
• executor::union::merge
• executor::wrapper::epoch_check::epoch_check
• executor::wrapper::epoch_provide::epoch_provide
• executor::wrapper::schema_check::schema_check
• executor::wrapper::trace::instrument_await_tree
• executor::wrapper::trace::trace
• executor::wrapper::update_check::update_check
• from_proto::agg_common::build_agg_state_storages_from_proto
• from_proto::agg_common::build_distinct_dedup_table_from_proto
• from_proto::create_executor
• from_proto::sink::resolve_pk_info
• from_proto::sink::telemetry_sink_build
• from_proto::sink::validate_payload_schema
• from_proto::source::get_connector_name
• from_proto::source::telemetry_source_build
• from_proto::source::trad_source::create_source_desc_builder
• task::barrier_manager::await_epoch_completed_future::instrument_complete_barrier_future
• task::barrier_manager::sync_epoch
• task::unique_executor_id
• task::unique_operator_id
• telemetry::report_event

Type Aliases

• common::compact_chunk::OpRowMap
• common::log_store_impl::kv_log_store::KvLogStorePkRow
• common::log_store_impl::kv_log_store::ReaderTruncationOffsetType
• common::log_store_impl::kv_log_store::RowOpCodeType
• common::log_store_impl::kv_log_store::SeqIdType
• common::log_store_impl::kv_log_store::reader::rewind_backoff_policy::RewindBackoffPolicy
• common::log_store_impl::kv_log_store::reader::timeout_auto_rebuild::TimeoutAutoRebuildIter
• common::log_store_impl::kv_log_store::serde::LogStoreItemMergeStream
• common::log_store_impl::kv_log_store::serde::PeekableLogStoreItemStream
• common::log_store_impl::kv_log_store::serde::stream_de::LogStoreItemStream
• common::table::state_table::ReplicatedStateTable
• common::table::state_table::StateTable
• common::table::state_table::WatermarkCacheParameterizedStateTable
• common::table::state_table::WatermarkCacheStateTable
• common::table::state_table_cache::WatermarkCacheKey
• error::StreamResult
• executor::ActorContextRef
• executor::AppendOnlyGroupTopNExecutor
• executor::AppendOnlyTopNExecutor
• executor::Barrier
• executor::BarrierMutationType
• executor::BoxedMessageStream
• executor::DispatcherBarrier
• executor::DispatcherMessage
• executor::DispatcherMessageStreamItem
• executor::GroupTopNExecutor
• executor::Message
• executor::MessageStreamItem
• executor::MessageStreamItemInner
• executor::PkDataTypes
• executor::PkIndices
• executor::PkIndicesRef
• executor::SplitAssignments
• executor::TopNExecutor
• executor::UpstreamFragmentId
• executor::actor::ActorContextRef
• executor::aggregation::agg_state_cache::CacheKey
• executor::aggregation::distinct::DedupCache
• executor::approx_percentile::global_state::BucketId
• executor::approx_percentile::global_state::BucketMap
• executor::approx_percentile::global_state::Count
• executor::backfill::arrangement_backfill::Builders
• executor::backfill::utils::BackfillRateLimiter
• executor::barrier_align::AlignedMessageStreamItem
• executor::error::StreamExecutorResult
• executor::exchange::input::BoxedInput
• executor::exchange::input::local_input::LocalInputStreamInner
• executor::exchange::input::remote_input::RemoteInputStreamInner
• executor::exchange::output::BoxedOutput
• executor::hash_agg::AggGroup
• executor::hash_agg::AggGroupCache
• executor::hash_agg::BoxedAggGroup
• executor::join::AsOfJoinTypePrimitive
• executor::join::JoinTypePrimitive
• executor::join::SideTypePrimitive
• executor::join::builder::IndexMappings
• executor::join::hash_join::HashValueType
• executor::join::hash_join::InequalKeyType
• executor::join::hash_join::JoinHashMapInner
• executor::join::hash_join::PkType
• executor::join::hash_join::StateValueType
• executor::join::row::DegreeType
• executor::lookup::cache::LookupEntryState
• executor::lookup::sides::BarrierAlignedMessage
• executor::mview::materialize::CacheValue
• executor::over_window::eowc::PartitionCache
• executor::over_window::over_partition::CacheKey
• executor::over_window::over_partition::PartitionCache
• executor::over_window::over_partition::PartitionDelta
• executor::prelude::Datum
• executor::prelude::DatumRef
• executor::sort_buffer::CacheKey
• executor::source::BackfillStates
• executor::source::fetch_executor::SplitBatch
• executor::source::source_backfill_executor::BackfillStates
• executor::stream_reader::ExecutorMessageStream
• executor::stream_reader::ReaderArm
• executor::stream_reader::StreamReaderData
• executor::stream_reader::stream_reader_with_pause::StreamReaderWithPauseInner
• executor::subtask::SubtaskHandle
• executor::test_utils::prelude::MemoryStateStore
• executor::top_n::group_top_n::GroupTopNExecutor
• executor::top_n::group_top_n_appendonly::AppendOnlyGroupTopNExecutor
• executor::top_n::top_n_appendonly::AppendOnlyTopNExecutor
• executor::top_n::top_n_cache::Cache
• executor::top_n::top_n_cache::CacheKey
• executor::top_n::top_n_plain::TopNExecutor
• executor::top_n::utils::CacheKeySerde
• task::ActorHandle
• task::ActorId
• task::AtomicU64Ref
• task::ConsumableChannelPair
• task::DispatcherId
• task::FragmentId
• task::UpDownActorIds
• task::UpDownFragmentIds
• task::barrier_manager::await_epoch_completed_future::AwaitEpochCompletedFuture
• task::barrier_manager::progress::ConsumedEpoch
• task::barrier_manager::progress::ConsumedRows
• task::env::WorkerNodeId
• task::stream_manager::ActorHandle
• task::stream_manager::AtomicU64Ref

Trait Aliases

• executor::DispatcherMessageStream
• executor::MessageStream
• executor::MessageStreamInner
• executor::barrier_align::AlignedMessageStream
• executor::dispatch::DispatchFuture
• executor::top_n::utils::GroupKey

Statics

• CONFIG
• common::compact_chunk::LOG_SUPPERSSER
• common::log_store_impl::kv_log_store::v1::KV_LOG_STORE_V1_INFO
• common::log_store_impl::kv_log_store::v2::KV_LOG_STORE_V2_INFO
• consistency::INSANE_MODE
• executor::monitor::streaming_stats::GLOBAL_STREAMING_METRICS

Constants

• cache::managed_lru::REPORT_SIZE_EVERY_N_KB_CHANGE
• common::log_store_impl::in_mem::UNINITIALIZED
• common::log_store_impl::kv_log_store::FIRST_SEQ_ID
• common::log_store_impl::kv_log_store::reader::REWIND_BACKOFF_FACTOR
• common::log_store_impl::kv_log_store::reader::REWIND_BASE_DELAY
• common::log_store_impl::kv_log_store::reader::REWIND_MAX_DELAY
• common::log_store_impl::kv_log_store::serde::BARRIER_OP_CODE
• common::log_store_impl::kv_log_store::serde::CHECKPOINT_BARRIER_OP_CODE
• common::log_store_impl::kv_log_store::serde::DELETE_OP_CODE
• common::log_store_impl::kv_log_store::serde::INSERT_OP_CODE
• common::log_store_impl::kv_log_store::serde::UPDATE_DELETE_OP_CODE
• common::log_store_impl::kv_log_store::serde::UPDATE_INSERT_OP_CODE
• common::table::state_table::WATERMARK_CACHE_ENTRIES
• executor::AsOfJoinType::Inner
• executor::AsOfJoinType::LeftOuter
• executor::INVALID_EPOCH
• executor::JoinType::FullOuter
• executor::JoinType::Inner
• executor::JoinType::LeftAnti
• executor::JoinType::LeftOuter
• executor::JoinType::LeftSemi
• executor::JoinType::RightAnti
• executor::JoinType::RightOuter
• executor::JoinType::RightSemi
• executor::asof_join::EVICT_EVERY_N_ROWS
• executor::backfill::cdc::cdc_backfill::METADATA_STATE_LEN
• executor::backfill::utils::METADATA_STATE_LEN
• executor::dml::MAX_CHUNK_FOR_ATOMICITY
• executor::exchange::permit::for_test::BATCHED_PERMITS
• executor::exchange::permit::for_test::CONCURRENT_BARRIERS
• executor::exchange::permit::for_test::INITIAL_PERMITS
• executor::hash_join::EVICT_EVERY_N_ROWS
• executor::join::AsOfJoinType::Inner
• executor::join::AsOfJoinType::LeftOuter
• executor::join::JoinType::FullOuter
• executor::join::JoinType::Inner
• executor::join::JoinType::LeftAnti
• executor::join::JoinType::LeftOuter
• executor::join::JoinType::LeftSemi
• executor::join::JoinType::RightAnti
• executor::join::JoinType::RightOuter
• executor::join::JoinType::RightSemi
• executor::join::SideType::Left
• executor::join::SideType::Right
• executor::join::join_row_set::MAX_VEC_SIZE
• executor::over_window::over_partition::MAGIC_BATCH_SIZE
• executor::over_window::over_partition::MAGIC_CACHE_SIZE
• executor::over_window::over_partition::MAGIC_JITTER_PREVENTION
• executor::project_set::PROJ_ROW_ID_OFFSET
• executor::sort_buffer::CACHE_CAPACITY
• executor::source::WAIT_BARRIER_MULTIPLE_TIMES
• executor::source::fetch_executor::SPLIT_BATCH_SIZE
• executor::source::fs_source_executor::WAIT_BARRIER_MULTIPLE_TIMES
• executor::source::source_executor::WAIT_BARRIER_MULTIPLE_TIMES
• executor::source::state_table_handler::COMPLETE_SPLIT_PREFIX
• executor::top_n::top_n_cache::TOPN_CACHE_HIGH_CAPACITY_FACTOR
• executor::top_n::top_n_cache::TOPN_CACHE_MIN_CAPACITY
• executor::top_n::utils::NO_GROUP_KEY
• executor::values::DEFAULT_CHUNK_SIZE
• executor::watermark_filter::UPDATE_GLOBAL_WATERMARK_FREQUENCY_WHEN_IDLE
• from_proto::source::trad_source::FS_CONNECTORS
• task::ENABLE_BARRIER_AGGREGATION
• task::barrier_manager::ENABLE_BARRIER_AGGREGATION
• telemetry::TELEMETRY_COMPUTE_REPORT_TYPE