List of all items
Structs
- ColumnStatistics
- PlanProperties
- Statistics
- TopK
- aggregates::AggregateExec
- aggregates::PhysicalGroupBy
- analyze::AnalyzeExec
- coalesce_batches::CoalesceBatchesExec
- coalesce_partitions::CoalescePartitionsExec
- common::IPCWriter
- display::DefaultDisplay
- display::DisplayableExecutionPlan
- display::OutputOrderingDisplay
- display::ProjectSchemaDisplay
- display::VerboseDisplay
- empty::EmptyExec
- explain::ExplainExec
- expressions::ApproxDistinct
- expressions::ApproxMedian
- expressions::ApproxPercentileCont
- expressions::ApproxPercentileContWithWeight
- expressions::ArrayAgg
- expressions::Avg
- expressions::AvgAccumulator
- expressions::BinaryExpr
- expressions::BitAnd
- expressions::BitOr
- expressions::BitXor
- expressions::BoolAnd
- expressions::BoolOr
- expressions::CaseExpr
- expressions::CastExpr
- expressions::Column
- expressions::Correlation
- expressions::Count
- expressions::CumeDist
- expressions::DistinctArrayAgg
- expressions::DistinctBitXor
- expressions::DistinctCount
- expressions::DistinctSum
- expressions::FirstValue
- expressions::Grouping
- expressions::InListExpr
- expressions::IsNotNullExpr
- expressions::IsNullExpr
- expressions::LastValue
- expressions::LikeExpr
- expressions::Literal
- expressions::Max
- expressions::MaxAccumulator
- expressions::Min
- expressions::MinAccumulator
- expressions::NegativeExpr
- expressions::NoOp
- expressions::NotExpr
- expressions::NthValue
- expressions::NthValueAgg
- expressions::Ntile
- expressions::OrderSensitiveArrayAgg
- expressions::PhysicalSortExpr
- expressions::Rank
- expressions::Regr
- expressions::RowNumber
- expressions::Stddev
- expressions::StddevPop
- expressions::StringAgg
- expressions::Sum
- expressions::TryCastExpr
- expressions::UnKnownColumn
- expressions::VariancePop
- expressions::WindowShift
- filter::FilterExec
- insert::DataSinkExec
- joins::CrossJoinExec
- joins::HashJoinExec
- joins::NestedLoopJoinExec
- joins::SortMergeJoinExec
- joins::SymmetricHashJoinExec
- joins::utils::ColumnIndex
- joins::utils::JoinFilter
- joins::utils::JoinHashMap
- limit::GlobalLimitExec
- limit::LimitStream
- limit::LocalLimitExec
- memory::MemoryExec
- memory::MemoryStream
- metrics::BaselineMetrics
- metrics::Count
- metrics::ExecutionPlanMetricsSet
- metrics::Gauge
- metrics::Label
- metrics::Metric
- metrics::MetricBuilder
- metrics::MetricsSet
- metrics::ScopedTimerGuard
- metrics::Time
- metrics::Timestamp
- placeholder_row::PlaceholderRowExec
- projection::ProjectionExec
- recursive_query::RecursiveQueryExec
- repartition::BatchPartitioner
- repartition::RepartitionExec
- sorts::RowIndex
- sorts::partial_sort::PartialSortExec
- sorts::sort::SortExec
- sorts::sort_preserving_merge::SortPreservingMergeExec
- stream::EmptyRecordBatchStream
- stream::RecordBatchReceiverStreamBuilder
- stream::RecordBatchStreamAdapter
- streaming::StreamingTableExec
- test::TestPartitionStream
- test::exec::BarrierExec
- test::exec::BatchIndex
- test::exec::BlockingExec
- test::exec::BlockingStream
- test::exec::ErrorExec
- test::exec::MockExec
- test::exec::PanicExec
- test::exec::StatisticsExec
- test::exec::TestStream
- tree_node::PlanContext
- udaf::AggregateFunctionExpr
- union::InterleaveExec
- union::UnionExec
- unnest::UnnestExec
- values::ValuesExec
- windows::BoundedWindowAggExec
- windows::BuiltInWindowExpr
- windows::PlainAggregateWindowExpr
- windows::WindowAggExec
- work_table::WorkTableExec
Enums
- ColumnarValue
- Distribution
- ExecutionMode
- InputOrderMode
- Partitioning
- aggregates::AggregateFunction
- aggregates::AggregateMode
- display::DisplayFormatType
- expressions::RankType
- expressions::RegrType
- expressions::StatsType
- functions::Hint
- joins::PartitionMode
- joins::StreamJoinPartitionMode
- joins::utils::StatefulStreamResult
- metrics::MetricValue
Traits
- Accumulator
- AggregateExpr
- ExecutionPlan
- ExecutionPlanProperties
- ExecutionPlanVisitor
- PhysicalExpr
- RecordBatchStream
- WindowExpr
- display::DisplayAs
- hash_utils::HashValue
- insert::DataSink
- joins::utils::JoinHashMapType
- metrics::RecordOutput
- streaming::PartitionStream
- windows::WindowExpr
Macros
Functions
- accept
- aggregates::concat_slices
- aggregates::create_aggregate_expr
- coalesce_batches::concat_batches
- collect
- collect_partitioned
- common::build_checked_file_list
- common::build_file_list
- common::can_project
- common::collect
- common::compute_record_batch_statistics
- common::get_meet_of_orderings
- display::display_orderings
- displayable
- execute_stream
- execute_stream_partitioned
- expressions::binary
- expressions::case
- expressions::cast
- expressions::col
- expressions::create_aggregate_expr
- expressions::cume_dist
- expressions::dense_rank
- expressions::format_state_name
- expressions::helpers::max
- expressions::helpers::min
- expressions::in_list
- expressions::is_not_null
- expressions::is_null
- expressions::lag
- expressions::lead
- expressions::like
- expressions::lit
- expressions::negative
- expressions::not
- expressions::percent_rank
- expressions::rank
- expressions::try_cast
- functions::columnar_values_to_array
- functions::create_physical_expr
- functions::make_scalar_function
- get_plan_string
- hash_utils::create_hashes
- hash_utils::create_row_hashes
- hash_utils::create_row_hashes_v2
- joins::utils::adjust_right_output_partitioning
- joins::utils::build_join_schema
- joins::utils::calculate_join_output_ordering
- joins::utils::check_join_is_valid
- joins::utils::partitioned_join_output_partitioning
- need_data_exchange
- project_schema
- sorts::streaming_merge::streaming_merge
- test::aggr_test_schema
- test::assert_is_pending
- test::build_table_i32
- test::build_table_scan_i32
- test::exec::assert_strong_count_converges_to_zero
- test::make_partition
- test::mem_exec
- test::scan_partitioned
- udaf::create_aggregate_expr
- udf::create_physical_expr
- union::can_interleave
- visit_execution_plan
- windows::create_window_expr
- windows::get_best_fitting_window
- windows::get_ordered_partition_by_indices
- windows::get_window_mode
- windows::schema_add_window_field
- with_new_children_if_necessary