List of all items
Structs
- datafusion::BridgeSender
- datafusion::BridgeStream
- datafusion::ChannelStreamSource
- datafusion::SortColumn
- datafusion::StreamBridge
- datafusion::StreamingScanExec
- datafusion::StreamingTableProvider
- datafusion::aggregate_bridge::DataFusionAccumulatorAdapter
- datafusion::aggregate_bridge::DataFusionAggregateFactory
- datafusion::execute::DdlResult
- datafusion::execute::QueryResult
- datafusion::watermark_udf::WatermarkUdf
- datafusion::window_udf::HopWindowStart
- datafusion::window_udf::SessionWindowStart
- datafusion::window_udf::TumbleWindowStart
- parser::CreateSinkStatement
- parser::CreateSourceStatement
- parser::FormatSpec
- parser::LateDataClause
- parser::StreamingParser
- parser::WatermarkDef
- parser::WindowRewriter
- parser::aggregation_parser::AggregateInfo
- parser::aggregation_parser::AggregationAnalysis
- parser::analytic_parser::AnalyticFunctionInfo
- parser::analytic_parser::AnalyticWindowAnalysis
- parser::analytic_parser::WindowFrameAnalysis
- parser::analytic_parser::WindowFrameInfo
- parser::join_parser::JoinAnalysis
- parser::join_parser::MultiJoinAnalysis
- parser::order_analyzer::OrderAnalysis
- parser::order_analyzer::OrderColumn
- planner::QueryPlan
- planner::SinkInfo
- planner::SourceInfo
- planner::StreamingPlanner
- planner::channel_derivation::ChannelDerivationResult
- planner::channel_derivation::MvDefinition
- planner::channel_derivation::SourceDefinition
- translator::AsofJoinTranslatorConfig
- translator::LookupJoinConfig
- translator::StreamJoinConfig
- translator::WindowOperatorConfig
- translator::analytic_translator::AnalyticFunctionConfig
- translator::analytic_translator::AnalyticWindowConfig
- translator::analytic_translator::WindowFrameConfig
- translator::analytic_translator::WindowFrameFunctionConfig
- translator::dag_planner::DagExplainOutput
- translator::having_translator::HavingFilterConfig
- translator::order_translator::PerGroupTopKConfig
- translator::order_translator::TopKConfig
- translator::order_translator::WatermarkSortConfig
- translator::order_translator::WindowLocalSortConfig
- translator::streaming_ddl::ColumnDefinition
- translator::streaming_ddl::SinkDefinition
- translator::streaming_ddl::SourceConfigOptions
- translator::streaming_ddl::SourceDefinition
- translator::streaming_ddl::WatermarkSpec
Enums
- Error
- datafusion::BridgeSendError
- datafusion::BridgeTrySendError
- datafusion::execute::StreamingSqlResult
- parser::EmitClause
- parser::EmitStrategy
- parser::ParseError
- parser::ShowCommand
- parser::SinkFrom
- parser::StreamingStatement
- parser::WindowFunction
- parser::aggregation_parser::AggregateType
- parser::analytic_parser::AnalyticFunctionType
- parser::analytic_parser::FrameBound
- parser::analytic_parser::FrameUnits
- parser::analytic_parser::WindowFrameFunction
- parser::join_parser::AsofSqlDirection
- parser::join_parser::JoinType
- parser::order_analyzer::OrderPattern
- parser::order_analyzer::RankType
- planner::PlanningError
- planner::StreamingPlan
- planner::channel_derivation::DerivedChannelType
- translator::AsofSqlJoinType
- translator::JoinOperatorConfig
- translator::LookupJoinType
- translator::StreamJoinType
- translator::WindowType
- translator::having_translator::HavingFilterError
- translator::order_translator::OrderOperatorConfig
- translator::streaming_ddl::BackpressureStrategy
- translator::streaming_ddl::WaitStrategy
Traits
Functions
- datafusion::aggregate_bridge::create_aggregate_factory
- datafusion::aggregate_bridge::lookup_aggregate_udf
- datafusion::aggregate_bridge::result_to_scalar_value
- datafusion::aggregate_bridge::scalar_value_to_result
- datafusion::create_streaming_context
- datafusion::execute::execute_streaming_sql
- datafusion::register_streaming_functions
- datafusion::register_streaming_functions_with_watermark
- parser::aggregation_parser::analyze_aggregates
- parser::aggregation_parser::count_aggregates
- parser::aggregation_parser::has_aggregates
- parser::analytic_parser::analyze_analytic_functions
- parser::analytic_parser::analyze_window_frames
- parser::interval_rewriter::rewrite_expr_mut
- parser::interval_rewriter::rewrite_interval_arithmetic
- parser::join_parser::analyze_join
- parser::join_parser::analyze_joins
- parser::join_parser::count_joins
- parser::join_parser::has_join
- parser::order_analyzer::analyze_order_by
- parser::order_analyzer::is_order_satisfied
- parser::parse_streaming_sql
- planner::channel_derivation::analyze_mv_sources
- planner::channel_derivation::derive_channel_types
- planner::channel_derivation::derive_channel_types_detailed
- translator::dag_planner::format_dag_explain
- translator::streaming_ddl::sql_type_to_arrow
- translator::streaming_ddl::translate_create_sink
- translator::streaming_ddl::translate_create_source