List of all items

Structs

• LogicalPlan
• PhysicalPlan
• PlanDiff
• PlanNode
• PlanSchema
• SchemaField
• cep::CepKeyState
• cep::CompiledPattern
• cep::PartialMatch
• cep::PartitionedCepMatcher
• cep::Pattern
• cep::PatternStage
• cep::SequentialPatternMatcher
• expression::ExprField
• expression::WindowFrame
• governance::AllowAllPolicyHook
• governance::StaticApiKeyAuthProvider
• optimizer::AqeOptimizer
• optimizer::AutoPartitionRule
• optimizer::BroadcastAutoRule
• optimizer::BroadcastRuntimeRule
• optimizer::CboCostModel
• optimizer::CoalesceAdvice
• optimizer::CoalesceRule
• optimizer::ColumnCboStats
• optimizer::ConstantFoldingRule
• optimizer::Cost
• optimizer::DppAdvice
• optimizer::DynamicPartitionPruningRule
• optimizer::FileStats
• optimizer::JoinReorderRule
• optimizer::OptimizeResult
• optimizer::Optimizer
• optimizer::PredicatePushdownRule
• optimizer::RuntimeStats
• optimizer::SkewAdvice
• optimizer::SkewJoinRule
• optimizer::SmallFilePlanner
• optimizer::SplitPlanAdvice
• optimizer::StaticCostModel
• optimizer::StreamingAqeGuard
• optimizer::TableCboStats
• optimizer::TableStatsRegistry
• optimizer::ThresholdSkewRule
• task_fragment::TypedTaskFragment
• udf::AggState
• udf::DefaultSandboxedExecutor
• udf::MultiplyScalarUdf
• udf::ResourceLimits
• udf::UdfRegistry
• window::FloatLiteral
• window::ParsedStreamFragment
• window::WindowAgg
• window::WindowExecutionSpec

Enums

• ExecutionKind
• FieldType
• JoinType
• NodeOp
• Partitioning
• PlanError
• cep::CepCompileError
• cep::UnsupportedCombinator
• expression::AggregateFunction
• expression::BinaryOperator
• expression::Expr
• expression::ExprDataType
• expression::IntervalUnit
• expression::NullOrdering
• expression::ScalarValue
• expression::SortDirection
• expression::TimeUnit
• expression::WindowFrameBound
• expression::WindowFrameUnits
• optimizer::OptimizerError
• udf::ScalarValue
• udf::UdfError
• udf::Volatility
• window::AggFilterCompareOp
• window::AggFilterValue
• window::WindowAggFilter
• window::WindowAggKind
• window::WindowKind

Traits

• governance::AuthProvider
• governance::PolicyHook
• optimizer::AqeRule
• optimizer::CostModel
• optimizer::OptimizerRule
• optimizer::SkewRule
• udf::AggregateUdf
• udf::CoGroupUdf
• udf::MapPandasIterUdf
• udf::SandboxedUdfExecutor
• udf::ScalarUdf
• udf::TableUdf

Functions

• cep::encode_cep_fragment
• diff_plans
• lower_to_physical
• optimizer::default_aqe_optimizer
• optimizer::default_aqe_optimizer_with_parallelism
• optimizer::default_aqe_optimizer_with_stats
• optimizer::default_aqe_optimizer_with_stats_and_parallelism
• optimizer::default_logical_optimizer
• optimizer::global_table_stats
• task_fragment::encode_typed_task_fragment
• task_fragment::execution_kind_from_fragment
• task_fragment::task_body_for_profile
• task_fragment::validate_job_fragments
• window::decode_window_execution_spec
• window::encode_stream_fragment
• window::encode_window_execution_spec
• window::parse_stream_fragment
• window::validate_window_execution_spec

Type Aliases

• optimizer::OptimizerResult

Constants

• MAX_PLAN_NODES
• cep::STREAM_CEP_PREFIX
• expression::EXPRESSION_FORMAT_VERSION
• optimizer::DEFAULT_BROADCAST_THRESHOLD_ROWS
• optimizer::DEFAULT_MAX_BROADCAST_BYTES
• optimizer::DEFAULT_SALT_FACTOR
• optimizer::DEFAULT_SKEW_THRESHOLD
• optimizer::DPP_MAX_BUILD_ROWS
• optimizer::DPP_MAX_KEYS
• task_fragment::TASK_FRAGMENT_VERSION
• window::WINDOW_EXECUTION_SPEC_PREFIX