List of all items

Structs

• error::BatchExternalSystemError
• execution::grpc_exchange::GrpcExchangeSource
• execution::local_exchange::LocalExchangeSource
• executor::ExecutorBuilder
• executor::ExecutorBuilderDescriptor
• executor::ExecutorInfo
• executor::FastInsertExecutor
• executor::ManagedExecutor
• executor::fast_insert::FastInsertExecutor
• executor::managed::ManagedExecutor
• executor::test_utils::BlockExecutor
• executor::test_utils::BusyLoopExecutor
• executor::test_utils::FakeExchangeSource
• executor::test_utils::MockExecutor
• 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
• 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::Executor
• rpc::service::exchange::ExchangeWriter
• task::BatchTaskContext
• task::channel::ChanReceiver
• task::channel::ChanSender
• task::context::BatchTaskContext

Macros

• error::anyhow
• executor::register_executor
• register_executor

Functions

• 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::BoxedDataChunkStream
• executor::BoxedExecutor
• 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::BUILDER_DESCS
• 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

• 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