List of all items
Structs
- catalog::ResolvedTableReference
- catalog::catalog::MemoryCatalogList
- catalog::catalog::MemoryCatalogProvider
- catalog::information_schema::InformationSchemaProvider
- catalog::listing_schema::ListingSchemaProvider
- catalog::schema::MemorySchemaProvider
- config::AggregateOptions
- config::CatalogOptions
- config::ConfigEntry
- config::ConfigOptions
- config::ExecutionOptions
- config::ExplainOptions
- config::Extensions
- config::OptimizerOptions
- config::ParquetOptions
- config::SqlParserOptions
- dataframe::DataFrame
- datasource::default_table_source::DefaultTableSource
- datasource::empty::EmptyTable
- datasource::file_format::avro::AvroFormat
- datasource::file_format::csv::CsvFormat
- datasource::file_format::file_type::FileCompressionType
- datasource::file_format::json::JsonFormat
- datasource::file_format::options::AvroReadOptions
- datasource::file_format::options::CsvReadOptions
- datasource::file_format::options::NdJsonReadOptions
- datasource::file_format::options::ParquetReadOptions
- datasource::file_format::parquet::ParquetFormat
- datasource::listing::FileRange
- datasource::listing::ListingOptions
- datasource::listing::ListingTable
- datasource::listing::ListingTableConfig
- datasource::listing::ListingTableUrl
- datasource::listing::PartitionedFile
- datasource::listing_table_factory::ListingTableFactory
- datasource::memory::MemTable
- datasource::object_store::DefaultObjectStoreRegistry
- datasource::object_store::ObjectStoreUrl
- datasource::streaming::StreamingTable
- datasource::view::ViewTable
- execution::DiskManager
- execution::context::ExecutionProps
- execution::context::SessionConfig
- execution::context::SessionContext
- execution::context::SessionState
- execution::context::TaskContext
- execution::disk_manager::DiskManager
- execution::memory_pool::FairSpillPool
- execution::memory_pool::GreedyMemoryPool
- execution::memory_pool::MemoryConsumer
- execution::memory_pool::MemoryReservation
- execution::memory_pool::UnboundedMemoryPool
- execution::runtime_env::RuntimeConfig
- execution::runtime_env::RuntimeEnv
- physical_optimizer::aggregate_statistics::AggregateStatistics
- physical_optimizer::coalesce_batches::CoalesceBatches
- physical_optimizer::combine_partial_final_agg::CombinePartialFinalAggregate
- physical_optimizer::dist_enforcement::EnforceDistribution
- physical_optimizer::global_sort_selection::GlobalSortSelection
- physical_optimizer::join_selection::JoinSelection
- physical_optimizer::pipeline_checker::PipelineChecker
- physical_optimizer::pipeline_checker::PipelineStatePropagator
- physical_optimizer::pipeline_fixer::PipelineFixer
- physical_optimizer::pruning::PruningPredicate
- physical_optimizer::repartition::Repartition
- physical_optimizer::sort_enforcement::EnforceSorting
- physical_plan::ColumnStatistics
- physical_plan::EmptyRecordBatchStream
- physical_plan::Statistics
- physical_plan::aggregates::AggregateExec
- physical_plan::aggregates::PhysicalGroupBy
- physical_plan::analyze::AnalyzeExec
- physical_plan::coalesce_batches::CoalesceBatchesExec
- physical_plan::coalesce_partitions::CoalescePartitionsExec
- physical_plan::common::AbortOnDropMany
- physical_plan::common::AbortOnDropSingle
- physical_plan::common::IPCWriter
- physical_plan::common::SizedRecordBatchStream
- physical_plan::display::DisplayableExecutionPlan
- physical_plan::empty::EmptyExec
- physical_plan::explain::ExplainExec
- physical_plan::expressions::ApproxDistinct
- physical_plan::expressions::ApproxMedian
- physical_plan::expressions::ApproxPercentileCont
- physical_plan::expressions::ApproxPercentileContWithWeight
- physical_plan::expressions::ArrayAgg
- physical_plan::expressions::Avg
- physical_plan::expressions::AvgAccumulator
- physical_plan::expressions::BinaryExpr
- physical_plan::expressions::CaseExpr
- physical_plan::expressions::CastExpr
- physical_plan::expressions::Column
- physical_plan::expressions::Correlation
- physical_plan::expressions::Count
- physical_plan::expressions::Covariance
- physical_plan::expressions::CovariancePop
- physical_plan::expressions::CumeDist
- physical_plan::expressions::DateTimeIntervalExpr
- physical_plan::expressions::DistinctArrayAgg
- physical_plan::expressions::DistinctCount
- physical_plan::expressions::DistinctSum
- physical_plan::expressions::GetIndexedFieldExpr
- physical_plan::expressions::Grouping
- physical_plan::expressions::InListExpr
- physical_plan::expressions::IsNotNullExpr
- physical_plan::expressions::IsNullExpr
- physical_plan::expressions::LikeExpr
- physical_plan::expressions::Literal
- physical_plan::expressions::Max
- physical_plan::expressions::MaxAccumulator
- physical_plan::expressions::Median
- physical_plan::expressions::Min
- physical_plan::expressions::MinAccumulator
- physical_plan::expressions::NegativeExpr
- physical_plan::expressions::NoOp
- physical_plan::expressions::NotExpr
- physical_plan::expressions::NthValue
- physical_plan::expressions::Ntile
- physical_plan::expressions::PhysicalSortExpr
- physical_plan::expressions::Rank
- physical_plan::expressions::RowNumber
- physical_plan::expressions::Stddev
- physical_plan::expressions::StddevPop
- physical_plan::expressions::Sum
- physical_plan::expressions::TryCastExpr
- physical_plan::expressions::UnKnownColumn
- physical_plan::expressions::Variance
- physical_plan::expressions::VariancePop
- physical_plan::expressions::WindowShift
- physical_plan::file_format::AvroExec
- physical_plan::file_format::CsvConfig
- physical_plan::file_format::CsvExec
- physical_plan::file_format::CsvOpener
- physical_plan::file_format::FileMeta
- physical_plan::file_format::FileScanConfig
- physical_plan::file_format::FileStream
- physical_plan::file_format::JsonOpener
- physical_plan::file_format::NdJsonExec
- physical_plan::file_format::ParquetExec
- physical_plan::file_format::ParquetFileMetrics
- physical_plan::filter::FilterExec
- physical_plan::joins::CrossJoinExec
- physical_plan::joins::HashJoinExec
- physical_plan::joins::NestedLoopJoinExec
- physical_plan::joins::SortMergeJoinExec
- physical_plan::joins::SymmetricHashJoinExec
- physical_plan::joins::utils::ColumnIndex
- physical_plan::joins::utils::JoinFilter
- physical_plan::limit::GlobalLimitExec
- physical_plan::limit::LocalLimitExec
- physical_plan::memory::MemoryExec
- physical_plan::memory::MemoryStream
- physical_plan::memory::MemoryWriteExec
- physical_plan::metrics::BaselineMetrics
- physical_plan::metrics::CompositeMetricsSet
- physical_plan::metrics::Count
- physical_plan::metrics::ExecutionPlanMetricsSet
- physical_plan::metrics::Gauge
- physical_plan::metrics::Label
- physical_plan::metrics::MemTrackingMetrics
- physical_plan::metrics::Metric
- physical_plan::metrics::MetricBuilder
- physical_plan::metrics::MetricsSet
- physical_plan::metrics::ScopedTimerGuard
- physical_plan::metrics::Time
- physical_plan::metrics::Timestamp
- physical_plan::planner::DefaultPhysicalPlanner
- physical_plan::projection::ProjectionExec
- physical_plan::repartition::BatchPartitioner
- physical_plan::repartition::RepartitionExec
- physical_plan::sorts::RowIndex
- physical_plan::sorts::sort::SortExec
- physical_plan::sorts::sort::SortOptions
- physical_plan::sorts::sort_preserving_merge::SortPreservingMergeExec
- physical_plan::stream::RecordBatchReceiverStream
- physical_plan::stream::RecordBatchStreamAdapter
- physical_plan::streaming::StreamingTableExec
- physical_plan::udaf::AggregateFunctionExpr
- physical_plan::udaf::AggregateUDF
- physical_plan::udf::ScalarUDF
- physical_plan::union::InterleaveExec
- physical_plan::union::UnionExec
- physical_plan::unnest::UnnestExec
- physical_plan::values::ValuesExec
- physical_plan::windows::BoundedWindowAggExec
- physical_plan::windows::BuiltInWindowExpr
- physical_plan::windows::PlainAggregateWindowExpr
- physical_plan::windows::WindowAggExec
- prelude::Column
- prelude::SessionConfig
- test_util::TestTableFactory
- test_util::TestTableProvider
- test_util::UnboundedExec
- test_util::parquet::ParquetScanOptions
- test_util::parquet::TestParquetFile
Enums
- catalog::TableReference
- datasource::TableType
- datasource::datasource::TableProviderFilterPushDown
- datasource::datasource::TableType
- datasource::file_format::file_type::FileType
- error::DataFusionError
- execution::disk_manager::DiskManagerConfig
- physical_plan::ColumnarValue
- physical_plan::Distribution
- physical_plan::Partitioning
- physical_plan::aggregates::AggregateFunction
- physical_plan::aggregates::AggregateMode
- physical_plan::aggregates::GroupByOrderMode
- physical_plan::display::DisplayFormatType
- physical_plan::expressions::RankType
- physical_plan::expressions::StatsType
- physical_plan::joins::PartitionMode
- physical_plan::joins::utils::JoinSide
- physical_plan::metrics::MetricValue
- physical_plan::windows::PartitionSearchMode
- prelude::Expr
- prelude::JoinType
- prelude::Partitioning
- scalar::ScalarValue
- variable::VarType
Traits
- catalog::catalog::CatalogList
- catalog::catalog::CatalogProvider
- catalog::schema::SchemaProvider
- config::ConfigExtension
- config::ExtensionOptions
- datasource::datasource::TableProvider
- datasource::datasource::TableProviderFactory
- datasource::file_format::FileFormat
- datasource::file_format::file_type::GetExt
- datasource::file_format::options::ReadOptions
- datasource::object_store::ObjectStoreRegistry
- datasource::streaming::PartitionStream
- execution::FunctionRegistry
- execution::context::DataFilePaths
- execution::context::QueryPlanner
- execution::memory_pool::MemoryPool
- execution::memory_pool::proxy::RawTableAllocExt
- execution::memory_pool::proxy::VecAllocExt
- execution::registry::FunctionRegistry
- from_slice::FromSlice
- physical_optimizer::optimizer::PhysicalOptimizerRule
- physical_optimizer::pruning::PruningStatistics
- physical_plan::Accumulator
- physical_plan::AggregateExpr
- physical_plan::ExecutionPlan
- physical_plan::ExecutionPlanVisitor
- physical_plan::PhysicalExpr
- physical_plan::RecordBatchStream
- physical_plan::RowAccumulator
- physical_plan::WindowExpr
- physical_plan::file_format::FileOpener
- physical_plan::file_format::ParquetFileReaderFactory
- physical_plan::metrics::RecordOutput
- physical_plan::planner::ExtensionPlanner
- physical_plan::planner::PhysicalPlanner
- physical_plan::windows::WindowExpr
- scalar::ScalarType
- variable::VarProvider
Macros
Functions
- avro_to_arrow::read_avro_schema_from_reader
- datasource::default_table_source::provider_as_source
- datasource::default_table_source::source_as_provider
- datasource::file_format::parquet::fetch_parquet_metadata
- datasource::get_statistics_with_limit
- execution::context::default_session_builder
- execution::memory_pool::human_readable_size
- physical_optimizer::join_selection::supports_swap
- physical_optimizer::join_selection::swap_hash_join
- physical_optimizer::join_selection::swap_join_type
- physical_optimizer::join_selection::swap_reverting_projection
- physical_optimizer::pipeline_checker::check_finiteness_requirements
- physical_plan::accept
- physical_plan::aggregates::create_aggregate_expr
- physical_plan::coalesce_batches::concat_batches
- physical_plan::collect
- physical_plan::collect_partitioned
- physical_plan::common::batch_byte_size
- physical_plan::common::build_checked_file_list
- physical_plan::common::build_file_list
- physical_plan::common::collect
- physical_plan::common::compute_record_batch_statistics
- physical_plan::common::get_meet_of_orderings
- physical_plan::common::transpose
- physical_plan::displayable
- physical_plan::execute_stream
- physical_plan::execute_stream_partitioned
- physical_plan::expressions::binary
- physical_plan::expressions::bitwise_not
- physical_plan::expressions::case
- physical_plan::expressions::cast
- physical_plan::expressions::cast_column
- physical_plan::expressions::cast_with_options
- physical_plan::expressions::col
- physical_plan::expressions::create_aggregate_expr
- physical_plan::expressions::cume_dist
- physical_plan::expressions::date_time_interval_expr
- physical_plan::expressions::dense_rank
- physical_plan::expressions::format_state_name
- physical_plan::expressions::helpers::max
- physical_plan::expressions::helpers::min
- physical_plan::expressions::in_list
- physical_plan::expressions::is_not_null
- physical_plan::expressions::is_null
- physical_plan::expressions::lag
- physical_plan::expressions::lead
- physical_plan::expressions::like
- physical_plan::expressions::lit
- physical_plan::expressions::negative
- physical_plan::expressions::not
- physical_plan::expressions::nullif_func
- physical_plan::expressions::percent_rank
- physical_plan::expressions::rank
- physical_plan::expressions::try_cast
- physical_plan::file_format::get_scan_files
- physical_plan::file_format::wrap_partition_type_in_dict
- physical_plan::file_format::wrap_partition_value_in_dict
- physical_plan::functions::create_physical_expr
- physical_plan::functions::create_physical_fun
- physical_plan::functions::make_scalar_function
- physical_plan::hash_utils::create_hashes
- physical_plan::hash_utils::create_row_hashes
- physical_plan::hash_utils::create_row_hashes_v2
- physical_plan::joins::utils::adjust_right_output_partitioning
- physical_plan::joins::utils::build_join_schema
- physical_plan::joins::utils::check_join_is_valid
- physical_plan::joins::utils::combine_join_equivalence_properties
- physical_plan::joins::utils::cross_join_equivalence_properties
- physical_plan::joins::utils::partitioned_join_output_partitioning
- physical_plan::need_data_exchange
- physical_plan::planner::create_aggregate_expr_and_maybe_filter
- physical_plan::planner::create_aggregate_expr_with_name_and_maybe_filter
- physical_plan::planner::create_physical_sort_expr
- physical_plan::planner::create_window_expr
- physical_plan::planner::create_window_expr_with_name
- physical_plan::planner::is_window_valid
- physical_plan::project_schema
- physical_plan::type_coercion::coerce
- physical_plan::udaf::create_aggregate_expr
- physical_plan::udf::create_physical_expr
- physical_plan::union::can_interleave
- physical_plan::visit_execution_plan
- physical_plan::windows::create_window_expr
- physical_plan::with_new_children_if_necessary
- prelude::abs
- prelude::acos
- prelude::acosh
- prelude::and
- prelude::approx_distinct
- prelude::approx_median
- prelude::approx_percentile_cont
- prelude::approx_percentile_cont_with_weight
- prelude::array
- prelude::arrow_typeof
- prelude::ascii
- prelude::asin
- prelude::asinh
- prelude::atan
- prelude::atan2
- prelude::atanh
- prelude::avg
- prelude::binary_expr
- prelude::bit_length
- prelude::bitwise_and
- prelude::bitwise_or
- prelude::bitwise_shift_left
- prelude::bitwise_shift_right
- prelude::bitwise_xor
- prelude::btrim
- prelude::call_fn
- prelude::case
- prelude::cast
- prelude::cbrt
- prelude::ceil
- prelude::character_length
- prelude::chr
- prelude::coalesce
- prelude::col
- prelude::concat
- prelude::concat_expr
- prelude::concat_ws
- prelude::concat_ws_expr
- prelude::cos
- prelude::cosh
- prelude::count
- prelude::count_distinct
- prelude::create_udaf
- prelude::create_udf
- prelude::cube
- prelude::current_date
- prelude::current_time
- prelude::date_bin
- prelude::date_part
- prelude::date_trunc
- prelude::degrees
- prelude::digest
- prelude::exists
- prelude::exp
- prelude::floor
- prelude::from_unixtime
- prelude::grouping_set
- prelude::ident
- prelude::in_list
- prelude::in_subquery
- prelude::initcap
- prelude::is_false
- prelude::is_not_false
- prelude::is_not_true
- prelude::is_not_unknown
- prelude::is_null
- prelude::is_true
- prelude::is_unknown
- prelude::left
- prelude::lit
- prelude::lit_timestamp_nano
- prelude::ln
- prelude::log
- prelude::log10
- prelude::log2
- prelude::lower
- prelude::lpad
- prelude::ltrim
- prelude::max
- prelude::md5
- prelude::median
- prelude::min
- prelude::not_exists
- prelude::not_in_subquery
- prelude::now
- prelude::nullif
- prelude::octet_length
- prelude::or
- prelude::out_ref_col
- prelude::pi
- prelude::power
- prelude::radians
- prelude::random
- prelude::regexp_match
- prelude::regexp_replace
- prelude::repeat
- prelude::replace
- prelude::reverse
- prelude::right
- prelude::rollup
- prelude::round
- prelude::rpad
- prelude::rtrim
- prelude::scalar_subquery
- prelude::sha224
- prelude::sha256
- prelude::sha384
- prelude::sha512
- prelude::signum
- prelude::sin
- prelude::sinh
- prelude::split_part
- prelude::sqrt
- prelude::starts_with
- prelude::stddev
- prelude::strpos
- prelude::substr
- prelude::substring
- prelude::sum
- prelude::tan
- prelude::tanh
- prelude::to_hex
- prelude::to_timestamp_micros
- prelude::to_timestamp_millis
- prelude::to_timestamp_seconds
- prelude::translate
- prelude::trim
- prelude::trunc
- prelude::try_cast
- prelude::upper
- prelude::uuid
- prelude::when
- test_util::aggr_test_schema
- test_util::aggr_test_schema_with_missing_col
- test_util::arrow_test_data
- test_util::get_data_dir
- test_util::get_test_context
- test_util::get_test_context2
- test_util::parquet_test_data
- test_util::register_unbounded_file_with_ordering
- test_util::scan_empty
- test_util::scan_empty_with_partitions
Type Definitions
- datasource::listing::PartitionedFileStream
- datasource::memory::PartitionData
- error::Result
- error::SharedResult
- physical_plan::SendableRecordBatchStream
- physical_plan::file_format::FileOpenFuture
- physical_plan::filter::EqualAndNonEqual
- physical_plan::joins::utils::JoinOn
- physical_plan::joins::utils::JoinOnRef
Constants
- DATAFUSION_VERSION
- catalog::information_schema::INFORMATION_SCHEMA_TABLES
- datasource::file_format::DEFAULT_SCHEMA_INFER_MAX_RECORD
- datasource::file_format::avro::DEFAULT_AVRO_EXTENSION
- datasource::file_format::csv::DEFAULT_CSV_EXTENSION
- datasource::file_format::json::DEFAULT_JSON_EXTENSION
- datasource::file_format::parquet::DEFAULT_PARQUET_EXTENSION
- physical_plan::expressions::DEFAULT_DATAFUSION_CAST_OPTIONS