List of all items
Structs
- catalog::ResolvedTableReference
- catalog::catalog::MemoryCatalogList
- catalog::catalog::MemoryCatalogProvider
- catalog::schema::MemorySchemaProvider
- config::BuiltInConfigs
- config::ConfigDefinition
- config::ConfigOptions
- dataframe::DataFrame
- datasource::default_table_source::DefaultTableSource
- datasource::empty::EmptyTable
- datasource::file_format::avro::AvroFormat
- datasource::file_format::csv::CsvFormat
- datasource::file_format::json::JsonFormat
- datasource::file_format::parquet::ParquetFormat
- datasource::listing::FileRange
- datasource::listing::ListingOptions
- datasource::listing::ListingTable
- datasource::listing::ListingTableConfig
- datasource::listing::ListingTableUrl
- datasource::listing::PartitionedFile
- datasource::memory::MemTable
- datasource::object_store::ObjectStoreRegistry
- datasource::object_store::ObjectStoreUrl
- datasource::view::ViewTable
- execution::context::ExecutionProps
- execution::context::SessionConfig
- execution::context::SessionContext
- execution::context::SessionState
- execution::context::TaskContext
- execution::disk_manager::DiskManager
- execution::memory_manager::MemoryConsumerId
- execution::memory_manager::MemoryManager
- execution::options::AvroReadOptions
- execution::options::CsvReadOptions
- execution::options::NdJsonReadOptions
- execution::options::ParquetReadOptions
- execution::runtime_env::RuntimeConfig
- execution::runtime_env::RuntimeEnv
- logical_plan::Column
- logical_plan::CreateCatalog
- logical_plan::CreateCatalogSchema
- logical_plan::CreateExternalTable
- logical_plan::CreateMemoryTable
- logical_plan::CreateView
- logical_plan::CrossJoin
- logical_plan::DFField
- logical_plan::DFSchema
- logical_plan::DropTable
- logical_plan::EmptyRelation
- logical_plan::Limit
- logical_plan::LogicalPlanBuilder
- logical_plan::Repartition
- logical_plan::StringifiedPlan
- logical_plan::Subquery
- logical_plan::TableScan
- logical_plan::Union
- logical_plan::Values
- logical_plan::plan::Aggregate
- logical_plan::plan::Analyze
- logical_plan::plan::CreateCatalog
- logical_plan::plan::CreateCatalogSchema
- logical_plan::plan::CreateExternalTable
- logical_plan::plan::CreateMemoryTable
- logical_plan::plan::CreateView
- logical_plan::plan::CrossJoin
- logical_plan::plan::Distinct
- logical_plan::plan::DropTable
- logical_plan::plan::EmptyRelation
- logical_plan::plan::Explain
- logical_plan::plan::Extension
- logical_plan::plan::Filter
- logical_plan::plan::GraphvizVisitor
- logical_plan::plan::IndentVisitor
- logical_plan::plan::Join
- logical_plan::plan::Limit
- logical_plan::plan::Projection
- logical_plan::plan::Repartition
- logical_plan::plan::Sort
- logical_plan::plan::StringifiedPlan
- logical_plan::plan::Subquery
- logical_plan::plan::SubqueryAlias
- logical_plan::plan::TableScan
- logical_plan::plan::Union
- logical_plan::plan::Values
- logical_plan::plan::Window
- logical_plan::window_frames::WindowFrame
- physical_optimizer::aggregate_statistics::AggregateStatistics
- physical_optimizer::coalesce_batches::CoalesceBatches
- physical_optimizer::hash_build_probe_order::HashBuildProbeOrder
- physical_optimizer::merge_exec::AddCoalescePartitionsExec
- physical_optimizer::pruning::PruningPredicate
- physical_optimizer::repartition::Repartition
- 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::cross_join::CrossJoinExec
- 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::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::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::NotExpr
- physical_plan::expressions::NthValue
- physical_plan::expressions::PhysicalSortExpr
- physical_plan::expressions::RowNumber
- physical_plan::expressions::Stddev
- physical_plan::expressions::StddevPop
- physical_plan::expressions::Sum
- physical_plan::expressions::TryCastExpr
- physical_plan::expressions::Variance
- physical_plan::expressions::VariancePop
- physical_plan::file_format::AvroExec
- physical_plan::file_format::CsvExec
- physical_plan::file_format::DEFAULT_PARTITION_COLUMN_DATATYPE
- physical_plan::file_format::FileMeta
- physical_plan::file_format::FileScanConfig
- physical_plan::file_format::FileStream
- physical_plan::file_format::NdJsonExec
- physical_plan::file_format::ParquetExec
- physical_plan::file_format::ParquetFileMetrics
- physical_plan::file_format::ParquetScanOptions
- physical_plan::filter::FilterExec
- physical_plan::hash_join::HashJoinExec
- physical_plan::join_utils::ColumnIndex
- physical_plan::join_utils::JoinFilter
- physical_plan::limit::GlobalLimitExec
- physical_plan::limit::LocalLimitExec
- physical_plan::memory::MemoryExec
- physical_plan::memory::MemoryStream
- 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::sort_merge_join::SortMergeJoinExec
- physical_plan::sorts::RowIndex
- physical_plan::sorts::SortKeyCursor
- 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::udaf::AggregateFunctionExpr
- physical_plan::udaf::AggregateUDF
- physical_plan::udf::ScalarUDF
- physical_plan::union::UnionExec
- physical_plan::values::ValuesExec
- physical_plan::windows::AggregateWindowExpr
- physical_plan::windows::BuiltInWindowExpr
- physical_plan::windows::WindowAggExec
- prelude::Column
Enums
- catalog::TableReference
- datasource::TableType
- datasource::datasource::TableProviderFilterPushDown
- datasource::datasource::TableType
- error::DataFusionError
- execution::context::TaskProperties
- execution::disk_manager::DiskManagerConfig
- execution::memory_manager::ConsumerType
- execution::memory_manager::MemoryManagerConfig
- logical_plan::Expr
- logical_plan::JoinConstraint
- logical_plan::JoinType
- logical_plan::LogicalPlan
- logical_plan::Operator
- logical_plan::Partitioning
- logical_plan::PlanType
- logical_plan::Recursion
- logical_plan::RewriteRecursion
- logical_plan::expr_rewriter::RewriteRecursion
- logical_plan::plan::JoinConstraint
- logical_plan::plan::JoinType
- logical_plan::plan::LogicalPlan
- logical_plan::plan::Partitioning
- logical_plan::plan::PlanType
- logical_plan::plan::TableProviderFilterPushDown
- logical_plan::window_frames::WindowFrameBound
- logical_plan::window_frames::WindowFrameUnits
- physical_plan::ColumnarValue
- physical_plan::Distribution
- physical_plan::Partitioning
- physical_plan::aggregates::AggregateFunction
- physical_plan::aggregates::AggregateMode
- physical_plan::display::DisplayFormatType
- physical_plan::expressions::StatsType
- physical_plan::hash_join::PartitionMode
- physical_plan::join_utils::JoinSide
- physical_plan::metrics::MetricValue
- prelude::Expr
- prelude::JoinType
- prelude::Partitioning
- scalar::ScalarValue
- variable::VarType
Traits
- catalog::catalog::CatalogList
- catalog::catalog::CatalogProvider
- catalog::schema::SchemaProvider
- datasource::datasource::TableProvider
- datasource::datasource::TableProviderFactory
- datasource::file_format::FileFormat
- datasource::object_store::ObjectStoreProvider
- execution::context::QueryPlanner
- execution::memory_manager::MemoryConsumer
- execution::registry::FunctionRegistry
- from_slice::FromSlice
- logical_plan::ExprRewritable
- logical_plan::ExprRewriter
- logical_plan::ExprSchema
- logical_plan::ExprSchemable
- logical_plan::ExprSimplifiable
- logical_plan::ExprVisitable
- logical_plan::ExpressionVisitor
- logical_plan::Literal
- logical_plan::PlanVisitor
- logical_plan::SimplifyInfo
- logical_plan::ToDFSchema
- logical_plan::ToStringifiedPlan
- logical_plan::UserDefinedLogicalNode
- logical_plan::expr_rewriter::ExprRewritable
- logical_plan::expr_rewriter::ExprRewriter
- logical_plan::plan::PlanVisitor
- logical_plan::plan::TableSource
- logical_plan::plan::ToStringifiedPlan
- logical_plan::plan::UserDefinedLogicalNode
- 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_manager::human_readable_size
- logical_plan::abs
- logical_plan::acos
- logical_plan::and
- logical_plan::approx_distinct
- logical_plan::approx_percentile_cont
- logical_plan::array
- logical_plan::ascii
- logical_plan::asin
- logical_plan::atan
- logical_plan::atan2
- logical_plan::avg
- logical_plan::bit_length
- logical_plan::btrim
- logical_plan::build_join_schema
- logical_plan::call_fn
- logical_plan::case
- logical_plan::cast
- logical_plan::ceil
- logical_plan::character_length
- logical_plan::chr
- logical_plan::coalesce
- logical_plan::col
- logical_plan::combine_filters
- logical_plan::concat
- logical_plan::concat_expr
- logical_plan::concat_ws
- logical_plan::concat_ws_expr
- logical_plan::cos
- logical_plan::count
- logical_plan::count_distinct
- logical_plan::create_udaf
- logical_plan::create_udf
- logical_plan::date_part
- logical_plan::date_trunc
- logical_plan::digest
- logical_plan::exists
- logical_plan::exp
- logical_plan::expr_rewriter::coerce_plan_expr_for_schema
- logical_plan::expr_rewriter::normalize_col
- logical_plan::expr_rewriter::normalize_col_with_schemas
- logical_plan::expr_rewriter::normalize_cols
- logical_plan::expr_rewriter::replace_col
- logical_plan::expr_rewriter::rewrite_sort_cols_by_aggs
- logical_plan::expr_rewriter::unnormalize_col
- logical_plan::expr_rewriter::unnormalize_cols
- logical_plan::floor
- logical_plan::from_unixtime
- logical_plan::in_list
- logical_plan::in_subquery
- logical_plan::initcap
- logical_plan::left
- logical_plan::length
- logical_plan::lit
- logical_plan::lit_timestamp_nano
- logical_plan::ln
- logical_plan::log10
- logical_plan::log2
- logical_plan::lower
- logical_plan::lpad
- logical_plan::ltrim
- logical_plan::max
- logical_plan::md5
- logical_plan::min
- logical_plan::normalize_col
- logical_plan::normalize_col_with_schemas
- logical_plan::normalize_cols
- logical_plan::not_exists
- logical_plan::not_in_subquery
- logical_plan::now
- logical_plan::nullif
- logical_plan::octet_length
- logical_plan::or
- logical_plan::power
- logical_plan::random
- logical_plan::regexp_match
- logical_plan::regexp_replace
- logical_plan::repeat
- logical_plan::replace
- logical_plan::replace_col
- logical_plan::reverse
- logical_plan::rewrite_sort_cols_by_aggs
- logical_plan::right
- logical_plan::round
- logical_plan::rpad
- logical_plan::rtrim
- logical_plan::scalar_subquery
- logical_plan::sha224
- logical_plan::sha256
- logical_plan::sha384
- logical_plan::sha512
- logical_plan::signum
- logical_plan::sin
- logical_plan::split_part
- logical_plan::sqrt
- logical_plan::starts_with
- logical_plan::strpos
- logical_plan::substr
- logical_plan::sum
- logical_plan::tan
- logical_plan::to_hex
- logical_plan::to_timestamp_micros
- logical_plan::to_timestamp_millis
- logical_plan::to_timestamp_seconds
- logical_plan::translate
- logical_plan::trim
- logical_plan::trunc
- logical_plan::unalias
- logical_plan::union_with_alias
- logical_plan::unnormalize_col
- logical_plan::unnormalize_cols
- logical_plan::upper
- logical_plan::when
- 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::displayable
- physical_plan::execute_stream
- physical_plan::execute_stream_partitioned
- physical_plan::expressions::binary
- 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::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::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::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::join_utils::build_join_schema
- physical_plan::join_utils::check_join_is_valid
- physical_plan::limit::truncate_batch
- physical_plan::planner::create_aggregate_expr
- physical_plan::planner::create_aggregate_expr_with_name
- physical_plan::planner::create_physical_sort_expr
- physical_plan::planner::create_window_expr
- physical_plan::planner::create_window_expr_with_name
- physical_plan::project_schema
- physical_plan::type_coercion::coerce
- physical_plan::udaf::create_aggregate_expr
- physical_plan::udf::create_physical_expr
- physical_plan::visit_execution_plan
- physical_plan::windows::create_window_expr
- physical_plan::with_new_children_if_necessary
- prelude::abs
- prelude::acos
- 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::atan
- prelude::atan2
- prelude::avg
- prelude::binary_expr
- prelude::bit_length
- prelude::btrim
- prelude::call_fn
- prelude::case
- prelude::cast
- prelude::ceil
- prelude::character_length
- prelude::chr
- prelude::coalesce
- prelude::col
- prelude::combine_filters
- prelude::combine_filters_disjunctive
- prelude::concat
- prelude::concat_expr
- prelude::concat_ws
- prelude::concat_ws_expr
- prelude::cos
- prelude::count
- prelude::count_distinct
- prelude::create_udaf
- prelude::create_udf
- prelude::cube
- prelude::date_bin
- prelude::date_part
- prelude::date_trunc
- prelude::digest
- prelude::exists
- prelude::exp
- prelude::floor
- prelude::from_unixtime
- prelude::grouping_set
- 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::length
- prelude::lit
- prelude::ln
- prelude::log10
- prelude::log2
- prelude::lower
- prelude::lpad
- prelude::ltrim
- prelude::max
- prelude::md5
- prelude::min
- prelude::not_exists
- prelude::not_in_subquery
- prelude::now
- prelude::nullif
- prelude::octet_length
- prelude::or
- prelude::power
- 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::split_part
- prelude::sqrt
- prelude::starts_with
- prelude::strpos
- prelude::substr
- prelude::sum
- prelude::tan
- 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::unalias
- prelude::uncombine_filter
- prelude::upper
- prelude::when
- test_util::aggr_test_schema
- test_util::aggr_test_schema_with_missing_col
- test_util::arrow_test_data
- test_util::parquet_test_data
- test_util::scan_empty
- test_util::scan_empty_with_partitions
Type Definitions
- datasource::listing::PartitionedFileStream
- error::Result
- logical_plan::DFSchemaRef
- physical_plan::SendableRecordBatchStream
- physical_plan::file_format::FileOpenFuture
- physical_plan::join_utils::JoinOn
- physical_plan::join_utils::JoinOnRef
Constants
- DATAFUSION_VERSION
- config::OPT_BATCH_SIZE
- config::OPT_COALESCE_BATCHES
- config::OPT_COALESCE_TARGET_BATCH_SIZE
- config::OPT_EXPLAIN_LOGICAL_PLAN_ONLY
- config::OPT_EXPLAIN_PHYSICAL_PLAN_ONLY
- config::OPT_FILTER_NULL_JOIN_KEYS
- config::OPT_OPTIMIZER_SKIP_FAILED_RULES
- config::OPT_TIME_ZONE
- 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
- execution::context::PARQUET_PRUNING
- execution::context::REPARTITION_AGGREGATIONS
- execution::context::REPARTITION_JOINS
- execution::context::REPARTITION_WINDOWS
- execution::context::TARGET_PARTITIONS
- logical_plan::UNNAMED_TABLE
- physical_plan::expressions::DEFAULT_DATAFUSION_CAST_OPTIONS