List of all items
Structs
- client::BallistaClient
- config::BallistaConfig
- config::BallistaConfigBuilder
- config::ConfigEntry
- event_loop::EventLoop
- event_loop::EventSender
- execution_plans::DistributedQueryExec
- execution_plans::ShuffleReaderExec
- execution_plans::ShuffleWriterExec
- execution_plans::UnresolvedShuffleExec
- plugin::PluginDeclaration
- plugin::plugin_manager::GlobalPluginManager
- plugin::udf::UDFPluginManager
- serde::BallistaCodec
- serde::DefaultLogicalExtensionCodec
- serde::DefaultPhysicalExtensionCodec
- serde::protobuf::Action
- serde::protobuf::AggregateExecNode
- serde::protobuf::AggregateNode
- serde::protobuf::AnalyzeNode
- serde::protobuf::AvroFormat
- serde::protobuf::AvroScanExecNode
- serde::protobuf::CoalesceBatchesExecNode
- serde::protobuf::CoalescePartitionsExecNode
- serde::protobuf::ColumnStats
- serde::protobuf::CompletedJob
- serde::protobuf::CompletedTask
- serde::protobuf::CreateCatalogNode
- serde::protobuf::CreateCatalogSchemaNode
- serde::protobuf::CreateExternalTableNode
- serde::protobuf::CreateViewNode
- serde::protobuf::CrossJoinExecNode
- serde::protobuf::CrossJoinNode
- serde::protobuf::CsvFormat
- serde::protobuf::CsvScanExecNode
- serde::protobuf::EmptyExecNode
- serde::protobuf::EmptyRelationNode
- serde::protobuf::ExecutePartition
- serde::protobuf::ExecuteQueryParams
- serde::protobuf::ExecuteQueryResult
- serde::protobuf::ExecuteSqlParams
- serde::protobuf::ExecutorData
- serde::protobuf::ExecutorHeartbeat
- serde::protobuf::ExecutorMetadata
- serde::protobuf::ExecutorMetric
- serde::protobuf::ExecutorRegistration
- serde::protobuf::ExecutorResource
- serde::protobuf::ExecutorResourcePair
- serde::protobuf::ExecutorSpecification
- serde::protobuf::ExecutorState
- serde::protobuf::ExplainExecNode
- serde::protobuf::ExplainNode
- serde::protobuf::FailedJob
- serde::protobuf::FailedTask
- serde::protobuf::FetchPartition
- serde::protobuf::FileGroup
- serde::protobuf::FilePartitionMetadata
- serde::protobuf::FileRange
- serde::protobuf::FileScanExecConf
- serde::protobuf::FilterExecNode
- serde::protobuf::GetFileMetadataParams
- serde::protobuf::GetFileMetadataResult
- serde::protobuf::GetJobStatusParams
- serde::protobuf::GetJobStatusResult
- serde::protobuf::GlobalLimitExecNode
- serde::protobuf::HashJoinExecNode
- serde::protobuf::HashRepartition
- serde::protobuf::HeartBeatParams
- serde::protobuf::HeartBeatResult
- serde::protobuf::JobSessionConfig
- serde::protobuf::JobStatus
- serde::protobuf::JoinNode
- serde::protobuf::JoinOn
- serde::protobuf::KeyValuePair
- serde::protobuf::LaunchTaskParams
- serde::protobuf::LaunchTaskResult
- serde::protobuf::LimitNode
- serde::protobuf::ListingTableScanNode
- serde::protobuf::LocalLimitExecNode
- serde::protobuf::LogicalExtensionNode
- serde::protobuf::LogicalPlanNode
- serde::protobuf::ParquetFormat
- serde::protobuf::ParquetScanExecNode
- serde::protobuf::PartitionId
- serde::protobuf::PartitionLocation
- serde::protobuf::PartitionStats
- serde::protobuf::PartitionedFile
- serde::protobuf::PhysicalAggregateExprNode
- serde::protobuf::PhysicalAliasNode
- serde::protobuf::PhysicalBinaryExprNode
- serde::protobuf::PhysicalCaseNode
- serde::protobuf::PhysicalCastNode
- serde::protobuf::PhysicalColumn
- serde::protobuf::PhysicalExprNode
- serde::protobuf::PhysicalExtensionNode
- serde::protobuf::PhysicalHashRepartition
- serde::protobuf::PhysicalInListNode
- serde::protobuf::PhysicalIsNotNull
- serde::protobuf::PhysicalIsNull
- serde::protobuf::PhysicalNegativeNode
- serde::protobuf::PhysicalNot
- serde::protobuf::PhysicalPlanNode
- serde::protobuf::PhysicalScalarFunctionNode
- serde::protobuf::PhysicalScalarUdfNode
- serde::protobuf::PhysicalSortExprNode
- serde::protobuf::PhysicalTryCastNode
- serde::protobuf::PhysicalWhenThen
- serde::protobuf::PhysicalWindowExprNode
- serde::protobuf::PollWorkParams
- serde::protobuf::PollWorkResult
- serde::protobuf::ProjectionColumns
- serde::protobuf::ProjectionExecNode
- serde::protobuf::ProjectionNode
- serde::protobuf::QueuedJob
- serde::protobuf::RegisterExecutorParams
- serde::protobuf::RegisterExecutorResult
- serde::protobuf::RepartitionExecNode
- serde::protobuf::RepartitionNode
- serde::protobuf::RunningJob
- serde::protobuf::RunningTask
- serde::protobuf::ScanLimit
- serde::protobuf::SelectionExecNode
- serde::protobuf::SelectionNode
- serde::protobuf::ShuffleReaderExecNode
- serde::protobuf::ShuffleReaderPartition
- serde::protobuf::ShuffleWritePartition
- serde::protobuf::ShuffleWriterExecNode
- serde::protobuf::SortExecNode
- serde::protobuf::SortNode
- serde::protobuf::Statistics
- serde::protobuf::StopExecutorParams
- serde::protobuf::StopExecutorResult
- serde::protobuf::SubqueryAliasNode
- serde::protobuf::TaskDefinition
- serde::protobuf::TaskStatus
- serde::protobuf::UnionExecNode
- serde::protobuf::UnionNode
- serde::protobuf::UnresolvedShuffleExecNode
- serde::protobuf::UpdateTaskStatusParams
- serde::protobuf::UpdateTaskStatusResult
- serde::protobuf::ValuesNode
- serde::protobuf::WindowAggExecNode
- serde::protobuf::WindowNode
- serde::protobuf::executor_grpc_client::ExecutorGrpcClient
- serde::protobuf::executor_grpc_server::ExecutorGrpcServer
- serde::protobuf::scheduler_grpc_client::SchedulerGrpcClient
- serde::protobuf::scheduler_grpc_server::SchedulerGrpcServer
- serde::scheduler::ExecutePartition
- serde::scheduler::ExecutePartitionResult
- serde::scheduler::ExecutorData
- serde::scheduler::ExecutorDataChange
- serde::scheduler::ExecutorMetadata
- serde::scheduler::ExecutorSpecification
- serde::scheduler::ExecutorState
- serde::scheduler::PartitionId
- serde::scheduler::PartitionLocation
- serde::scheduler::PartitionStats
- utils::BallistaQueryPlanner
Enums
- config::TaskSchedulingPolicy
- error::BallistaError
- plugin::PluginEnum
- serde::protobuf::AggregateMode
- serde::protobuf::FileType
- serde::protobuf::JoinConstraint
- serde::protobuf::JoinType
- serde::protobuf::PartitionMode
- serde::protobuf::action::ActionType
- serde::protobuf::execute_query_params::OptionalSessionId
- serde::protobuf::execute_query_params::Query
- serde::protobuf::executor_metric::Metric
- serde::protobuf::executor_registration::OptionalHost
- serde::protobuf::executor_resource::Resource
- serde::protobuf::job_status::Status
- serde::protobuf::listing_table_scan_node::FileFormatType
- serde::protobuf::logical_plan_node::LogicalPlanType
- serde::protobuf::physical_expr_node::ExprType
- serde::protobuf::physical_plan_node::PhysicalPlanType
- serde::protobuf::physical_window_expr_node::WindowFunction
- serde::protobuf::projection_node::OptionalAlias
- serde::protobuf::repartition_exec_node::PartitionMethod
- serde::protobuf::repartition_node::PartitionMethod
- serde::protobuf::task_status::Status
- serde::scheduler::Action
Traits
- event_loop::EventAction
- plugin::Plugin
- plugin::PluginRegistrar
- plugin::udf::UDFPlugin
- serde::AsExecutionPlan
- serde::AsLogicalPlan
- serde::LogicalExtensionCodec
- serde::PhysicalExtensionCodec
- serde::protobuf::executor_grpc_server::ExecutorGrpc
- serde::protobuf::scheduler_grpc_server::SchedulerGrpc
Macros
- convert_box_required
- convert_required
- declare_plugin
- declare_udf_plugin
- into_logical_plan
- into_physical_plan
- into_required
Functions
- error::ballista_error
- plugin::plugin_dir
- plugin::plugin_manager::global_plugin_manager
- plugin::udf::get_udf_plugin_manager
- print_version
- serde::decode_protobuf
- serde::physical_plan::from_proto::parse_protobuf_hash_partitioning
- serde::scheduler::to_proto::hash_partitioning_to_proto
- utils::collect_stream
- utils::create_df_ctx_with_ballista_query_planner
- utils::produce_diagram
- utils::write_stream_to_disk
Typedefs
Statics
Constants
- BALLISTA_VERSION
- config::BALLISTA_DEFAULT_BATCH_SIZE
- config::BALLISTA_DEFAULT_SHUFFLE_PARTITIONS
- config::BALLISTA_PARQUET_PRUNING
- config::BALLISTA_PLUGIN_DIR
- config::BALLISTA_REPARTITION_AGGREGATIONS
- config::BALLISTA_REPARTITION_JOINS
- config::BALLISTA_REPARTITION_WINDOWS
- config::BALLISTA_WITH_INFORMATION_SCHEMA