List of all items

Structs

• error::BatchExternalSystemError
• execution::grpc_exchange::GrpcExchangeSource
• execution::local_exchange::LocalExchangeSource
• executor::AggSpillManager
• executor::AsOf
• executor::BufferChunkExecutor
• executor::DefaultCreateSource
• executor::DeleteExecutor
• executor::DistributedLookupJoinExecutor
• executor::DistributedLookupJoinExecutorBuilder
• executor::DummyExecutor
• executor::EquiJoinParams
• executor::ExecutorBuilder
• executor::ExecutorInfo
• executor::ExpandExecutor
• executor::FilterExecutor
• executor::GenericExchangeExecutor
• executor::GenericExchangeExecutorBuilder
• executor::GroupTopNExecutor
• executor::GroupTopNExecutorBuilder
• executor::HashAggExecutor
• executor::HashAggExecutorBuilder
• executor::HashJoinExecutor
• executor::HopWindowExecutor
• executor::IcebergScanExecutor
• executor::IcebergScanExecutorBuilder
• executor::InsertExecutor
• executor::JoinSpillManager
• executor::LimitExecutor
• executor::LocalLookupJoinExecutor
• executor::LocalLookupJoinExecutorBuilder
• executor::LookupJoinBase
• executor::ManagedExecutor
• executor::MaxOneRowExecutor
• executor::MergeSortExchangeExecutorBuilder
• executor::MergeSortExchangeExecutorImpl
• executor::MergeSortExecutor
• executor::MySqlQueryExecutor
• executor::MySqlQueryExecutorBuilder
• executor::NestedLoopJoinExecutor
• executor::PostgresQueryExecutor
• executor::PostgresQueryExecutorBuilder
• executor::ProjectExecutor
• executor::ProjectSetExecutor
• executor::RowId
• executor::RowSeqScanExecutor
• executor::RowSeqScanExecutorBuilder
• executor::ScanRange
• executor::SortAggExecutor
• executor::SortExecutor
• executor::SortOverWindowExecutor
• executor::SourceExecutor
• executor::TableFunctionExecutor
• executor::TableFunctionExecutorBuilder
• executor::TopNExecutor
• executor::UnionExecutor
• executor::UpdateExecutor
• executor::ValuesExecutor
• executor::WrapStreamExecutor
• executor::aggregation::distinct::Distinct
• executor::aggregation::distinct::State
• executor::aggregation::filter::Filter
• executor::aggregation::orderby::ProjectionOrderBy
• executor::aggregation::orderby::State
• executor::aggregation::projection::Projection
• executor::delete::DeleteExecutor
• executor::expand::ExpandExecutor
• executor::filter::FilterExecutor
• executor::generic_exchange::DefaultCreateSource
• executor::generic_exchange::GenericExchangeExecutor
• executor::generic_exchange::GenericExchangeExecutorBuilder
• executor::group_top_n::GroupTopNExecutor
• executor::group_top_n::GroupTopNExecutorBuilder
• executor::hash_agg::AggSpillManager
• executor::hash_agg::HashAggExecutor
• executor::hash_agg::HashAggExecutorBuilder
• executor::hash_join::EquiJoinParams
• executor::hash_join::HashJoinExecutor
• executor::hash_join::JoinSpillManager
• executor::hop_window::HopWindowExecutor
• executor::iceberg_scan::EqualityDeleteFilter
• executor::iceberg_scan::IcebergScanExecutor
• executor::iceberg_scan::IcebergScanExecutorBuilder
• executor::iceberg_scan::PositionDeleteFilter
• executor::insert::InsertExecutor
• executor::join::chunked_data::AllRowIdIter
• executor::join::chunked_data::ChunkedData
• executor::join::chunked_data::RowId
• executor::join::distributed_lookup_join::DistributedLookupJoinExecutor
• executor::join::distributed_lookup_join::DistributedLookupJoinExecutorArgs
• executor::join::distributed_lookup_join::DistributedLookupJoinExecutorBuilder
• executor::join::distributed_lookup_join::InnerSideExecutorBuilder
• executor::join::hash_join::DataChunkMutator
• executor::join::hash_join::EquiJoinParams
• executor::join::hash_join::HashJoinExecutor
• executor::join::hash_join::HashJoinExecutorArgs
• executor::join::hash_join::JoinSpillManager
• executor::join::hash_join::LeftNonEquiJoinState
• executor::join::hash_join::RightNonEquiJoinState
• executor::join::hash_join::RowIdIter
• executor::join::local_lookup_join::InnerSideExecutorBuilder
• executor::join::local_lookup_join::LocalLookupJoinExecutor
• executor::join::local_lookup_join::LocalLookupJoinExecutorArgs
• executor::join::local_lookup_join::LocalLookupJoinExecutorBuilder
• executor::join::lookup_join_base::LookupJoinBase
• executor::join::nested_loop_join::NestedLoopJoinExecutor
• executor::limit::LimitExecutor
• executor::local_lookup_join::LocalLookupJoinExecutor
• executor::local_lookup_join::LocalLookupJoinExecutorBuilder
• executor::log_row_seq_scan::LogRowSeqScanExecutor
• executor::log_row_seq_scan::LogStoreRowSeqScanExecutorBuilder
• executor::managed::ManagedExecutor
• executor::max_one_row::MaxOneRowExecutor
• executor::merge_sort::MergeSortExecutor
• executor::merge_sort_exchange::MergeSortExchangeExecutorBuilder
• executor::merge_sort_exchange::MergeSortExchangeExecutorImpl
• executor::mysql_query::MySqlQueryExecutor
• executor::mysql_query::MySqlQueryExecutorBuilder
• executor::nested_loop_join::NestedLoopJoinExecutor
• executor::order_by::SortExecutor
• executor::order_by::SortSpillManager
• executor::postgres_query::PostgresQueryExecutor
• executor::postgres_query::PostgresQueryExecutorBuilder
• executor::project::ProjectExecutor
• executor::project_set::ProjectSetExecutor
• executor::row_seq_scan::AsOf
• executor::row_seq_scan::RowSeqScanExecutor
• executor::row_seq_scan::RowSeqScanExecutorBuilder
• executor::row_seq_scan::ScanRange
• executor::s3_file_scan::FileScanExecutorBuilder
• executor::s3_file_scan::S3FileScanExecutor
• executor::sort_agg::EqGroups
• executor::sort_agg::EqGroupsIter
• executor::sort_agg::SortAggExecutor
• executor::sort_over_window::ExecutorInner
• executor::sort_over_window::SortOverWindowExecutor
• executor::source::SourceExecutor
• executor::sys_row_seq_scan::SysRowSeqScanExecutor
• executor::sys_row_seq_scan::SysRowSeqScanExecutorBuilder
• executor::table_function::TableFunctionExecutor
• executor::table_function::TableFunctionExecutorBuilder
• executor::test_utils::BlockExecutor
• executor::test_utils::BlockExecutorBuilder
• executor::test_utils::BusyLoopExecutor
• executor::test_utils::BusyLoopExecutorBuilder
• executor::test_utils::FakeCreateSource
• executor::test_utils::FakeExchangeSource
• executor::test_utils::FakeInnerSideExecutorBuilder
• executor::test_utils::MockExecutor
• executor::top_n::HeapElem
• executor::top_n::TopNExecutor
• executor::top_n::TopNHeap
• executor::union::UnionExecutor
• executor::update::UpdateExecutor
• executor::utils::BufferChunkExecutor
• executor::utils::DummyExecutor
• executor::utils::WrapStreamExecutor
• executor::values::ValuesExecutor
• monitor::stats::BatchExecutorMetrics
• monitor::stats::BatchManagerMetrics
• monitor::stats::BatchMetricsInner
• monitor::stats::BatchSpillMetrics
• monitor::stats::IcebergScanMetrics
• rpc::service::exchange::GrpcExchangeWriter
• rpc::service::task_service::BatchServiceImpl
• spill::spill_op::SpillBuildHasher
• spill::spill_op::SpillOp
• task::BatchEnvironment
• task::BatchManager
• task::BatchTaskExecution
• task::ComputeNodeContext
• task::ShutdownSender
• task::ShutdownToken
• task::TaskId
• task::TaskOutput
• task::TaskOutputId
• task::broadcast_channel::BroadcastReceiver
• task::broadcast_channel::BroadcastSender
• task::consistent_hash_shuffle_channel::ConsistentHashShuffleReceiver
• task::consistent_hash_shuffle_channel::ConsistentHashShuffleSender
• task::context::ComputeNodeContext
• task::data_chunk_in_channel::DataChunkInChannel
• task::env::BatchEnvironment
• task::fifo_channel::FifoReceiver
• task::fifo_channel::FifoSender
• task::hash_shuffle_channel::HashShuffleReceiver
• task::hash_shuffle_channel::HashShuffleSender
• task::task_execution::BatchTaskExecution
• task::task_execution::ShutdownSender
• task::task_execution::ShutdownToken
• task::task_execution::TaskId
• task::task_execution::TaskOutput
• task::task_execution::TaskOutputId
• task::task_manager::BatchManager
• worker_manager::worker_node_manager::WorkerNodeManager
• worker_manager::worker_node_manager::WorkerNodeManagerInner
• worker_manager::worker_node_manager::WorkerNodeSelector

Enums

• error::BatchError
• exchange_source::ExchangeSourceImpl
• executor::JoinType
• executor::ProjectSetSelectItem
• executor::join::JoinType
• executor::project_set::ProjectSetSelectItem
• executor::s3_file_scan::FileFormat
• spill::spill_op::SpillBackend
• task::ShutdownMsg
• task::StateReporter
• task::channel::ChanReceiverImpl
• task::channel::ChanSenderImpl
• task::task_execution::ShutdownMsg
• task::task_execution::StateReporter

Traits

• exchange_source::ExchangeSource
• executor::BoxedExecutorBuilder
• executor::CreateSource
• executor::Executor
• executor::LookupExecutorBuilder
• executor::generic_exchange::CreateSource
• executor::join::local_lookup_join::LookupExecutorBuilder
• executor::local_lookup_join::LookupExecutorBuilder
• rpc::service::exchange::ExchangeWriter
• task::BatchTaskContext
• task::channel::ChanReceiver
• task::channel::ChanSender
• task::context::BatchTaskContext

Macros

• error::anyhow
• executor::build_executor

Functions

• executor::aggregation::build
• executor::batch_read
• executor::join::concatenate
• executor::join::convert_datum_refs_to_chunk
• executor::join::convert_row_to_chunk
• executor::mysql_query::mysql_row_to_owned_row
• executor::mysql_row_to_owned_row
• executor::postgres_query::postgres_cell_to_scalar_impl
• executor::postgres_query::postgres_row_to_owned_row
• executor::postgres_row_to_owned_row
• executor::row_seq_scan::unix_timestamp_sec_to_epoch
• executor::source::covert_stream_chunk_to_batch_chunk
• executor::test_utils::diff_executor_output
• executor::test_utils::gen_data
• executor::test_utils::gen_projected_data
• executor::test_utils::gen_sorted_data
• executor::test_utils::is_data_chunk_eq
• executor::unix_timestamp_sec_to_epoch
• executor::utils::batch_read
• task::broadcast_channel::new_broadcast_channel
• task::channel::create_output_channel
• task::consistent_hash_shuffle_channel::generate_hash_values
• task::consistent_hash_shuffle_channel::generate_new_data_chunks
• task::consistent_hash_shuffle_channel::new_consistent_shuffle_channel
• task::fifo_channel::new_fifo_channel
• task::hash_shuffle_channel::generate_hash_values
• task::hash_shuffle_channel::generate_new_data_chunks
• task::hash_shuffle_channel::new_hash_shuffle_channel

Type Aliases

• error::Result
• error::SharedResult
• executor::BoxedDataChunkListStream
• executor::BoxedDataChunkStream
• executor::BoxedExecutor
• executor::BoxedLookupExecutorBuilder
• executor::ExchangeExecutor
• executor::JoinHashMap
• executor::MergeSortExchangeExecutor
• executor::aggregation::orderby::OrderKey
• executor::generic_exchange::ExchangeExecutor
• executor::hash_agg::AggHashMap
• executor::hash_join::JoinHashMap
• executor::join::hash_join::JoinHashMap
• executor::join::local_lookup_join::BoxedLookupExecutorBuilder
• executor::local_lookup_join::BoxedLookupExecutorBuilder
• executor::merge_sort_exchange::MergeSortExchangeExecutor
• executor::utils::BoxedDataChunkListStream
• monitor::stats::BatchMetrics
• rpc::service::exchange::ExchangeDataSender
• rpc::service::exchange::GetDataResponseResult
• rpc::service::task_service::GetDataResponseResult
• rpc::service::task_service::TaskInfoResponseResult
• worker_manager::worker_node_manager::FragmentId
• worker_manager::worker_node_manager::WorkerNodeManagerRef

Trait Aliases

• error::Error

Statics

• executor::iceberg_scan::POSITION_DELETE_FILE_FILE_PATH_INDEX
• executor::iceberg_scan::POSITION_DELETE_FILE_POS
• monitor::stats::GLOBAL_BATCH_EXECUTOR_METRICS
• monitor::stats::GLOBAL_BATCH_MANAGER_METRICS
• monitor::stats::GLOBAL_BATCH_SPILL_METRICS
• monitor::stats::GLOBAL_ICEBERG_SCAN_METRICS

Constants

• executor::join::lookup_join_base::AT_LEAST_OUTER_SIDE_ROWS
• executor::test_utils::SEED
• executor::top_n::MAX_TOPN_INIT_HEAP_CAPACITY
• rpc::service::task_service::LOCAL_EXECUTE_BUFFER_SIZE
• spill::spill_op::DEFAULT_IO_BUFFER_SIZE
• spill::spill_op::DEFAULT_IO_CONCURRENT_TASK
• spill::spill_op::DEFAULT_SPILL_DIR
• spill::spill_op::DEFAULT_SPILL_PARTITION_NUM
• spill::spill_op::RW_BATCH_SPILL_DIR_ENV
• spill::spill_op::RW_MANAGED_SPILL_DIR
• spill::spill_op::SPILL_AT_LEAST_MEMORY
• task::TASK_STATUS_BUFFER_SIZE
• task::task_execution::TASK_STATUS_BUFFER_SIZE