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::complex_type_lambda::ArrayFilter
• datafusion::complex_type_lambda::ArrayReduce
• datafusion::complex_type_lambda::ArrayTransform
• datafusion::complex_type_lambda::MapFilter
• datafusion::complex_type_lambda::MapTransformValues
• datafusion::complex_type_udf::MapContainsKey
• datafusion::complex_type_udf::MapFromArrays
• datafusion::complex_type_udf::MapKeys
• datafusion::complex_type_udf::MapValues
• datafusion::complex_type_udf::StructDrop
• datafusion::complex_type_udf::StructExtract
• datafusion::complex_type_udf::StructMerge
• datafusion::complex_type_udf::StructRename
• datafusion::complex_type_udf::StructSet
• datafusion::execute::DdlResult
• datafusion::execute::QueryResult
• datafusion::format_bridge_udf::FromJsonUdf
• datafusion::format_bridge_udf::ParseEpochUdf
• datafusion::format_bridge_udf::ParseTimestampUdf
• datafusion::format_bridge_udf::ToJsonUdf
• datafusion::json_extensions::JsonInferSchema
• datafusion::json_extensions::JsonToColumns
• datafusion::json_extensions::JsonbDeepMerge
• datafusion::json_extensions::JsonbExcept
• datafusion::json_extensions::JsonbFlatten
• datafusion::json_extensions::JsonbMerge
• datafusion::json_extensions::JsonbPick
• datafusion::json_extensions::JsonbRenameKeys
• datafusion::json_extensions::JsonbStripNulls
• datafusion::json_extensions::JsonbUnflatten
• datafusion::json_path::CompiledJsonPath
• datafusion::json_path::JsonbPathExistsUdf
• datafusion::json_path::JsonbPathMatchUdf
• datafusion::json_tvf::JsonbArrayElementsTextTvf
• datafusion::json_tvf::JsonbArrayElementsTvf
• datafusion::json_tvf::JsonbEachTextTvf
• datafusion::json_tvf::JsonbEachTvf
• datafusion::json_tvf::JsonbObjectKeysTvf
• datafusion::json_udaf::JsonAgg
• datafusion::json_udaf::JsonObjectAgg
• datafusion::json_udf::JsonBuildArray
• datafusion::json_udf::JsonBuildObject
• datafusion::json_udf::JsonTypeof
• datafusion::json_udf::JsonbContainedBy
• datafusion::json_udf::JsonbContains
• datafusion::json_udf::JsonbExists
• datafusion::json_udf::JsonbExistsAll
• datafusion::json_udf::JsonbExistsAny
• datafusion::json_udf::JsonbGet
• datafusion::json_udf::JsonbGetIdx
• datafusion::json_udf::JsonbGetPath
• datafusion::json_udf::JsonbGetPathText
• datafusion::json_udf::JsonbGetText
• datafusion::json_udf::JsonbGetTextIdx
• datafusion::json_udf::ToJsonb
• datafusion::lookup_join::JoinKeyPair
• datafusion::lookup_join::LookupJoinNode
• datafusion::lookup_join::LookupTableMetadata
• datafusion::proctime_udf::ProcTimeUdf
• datafusion::watermark_udf::WatermarkUdf
• datafusion::window_udf::CumulateWindowStart
• datafusion::window_udf::HopWindowStart
• datafusion::window_udf::SessionWindowStart
• datafusion::window_udf::TumbleWindowStart
• error::TranslatedError
• 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::lookup_table::ByteSize
• parser::lookup_table::CreateLookupTableStatement
• parser::lookup_table::LookupTableProperties
• parser::order_analyzer::OrderAnalysis
• parser::order_analyzer::OrderColumn
• planner::LookupTableInfo
• planner::QueryPlan
• planner::SinkInfo
• planner::SourceInfo
• planner::StreamingPlanner
• planner::channel_derivation::ChannelDerivationResult
• planner::channel_derivation::MvDefinition
• planner::channel_derivation::SourceDefinition
• planner::lookup_join::LookupColumnPruningRule
• planner::lookup_join::LookupJoinRewriteRule
• planner::predicate_split::PlanSourceCapabilities
• planner::predicate_split::PredicateClassifier
• planner::predicate_split::PredicateSplitterRule
• planner::predicate_split::SourceCapabilitiesRegistry
• translator::AsofJoinTranslatorConfig
• translator::LookupJoinConfig
• translator::StreamJoinConfig
• translator::TemporalJoinTranslatorConfig
• 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
• datafusion::json_path::JsonPathStep
• datafusion::lookup_join::LookupJoinType
• parser::AlterSourceOperation
• 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::lookup_table::ConnectorType
• parser::lookup_table::LookupStrategy
• parser::lookup_table::PushdownMode
• parser::order_analyzer::OrderPattern
• parser::order_analyzer::RankType
• planner::PlanningError
• planner::StreamingPlan
• planner::channel_derivation::DerivedChannelType
• planner::predicate_split::PlanPushdownMode
• planner::predicate_split::PredicateClass
• 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

• datafusion::StreamSource

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::complex_type_lambda::register_lambda_functions
• datafusion::complex_type_udf::register_complex_type_functions
• datafusion::create_streaming_context
• datafusion::execute::execute_streaming_sql
• datafusion::json_extensions::register_json_extensions
• datafusion::json_tvf::register_json_table_functions
• datafusion::json_types::encode_jsonb
• datafusion::json_types::encode_jsonb_into
• datafusion::json_types::jsonb_array_get
• datafusion::json_types::jsonb_contains
• datafusion::json_types::jsonb_get_field
• datafusion::json_types::jsonb_has_key
• datafusion::json_types::jsonb_to_text
• datafusion::json_types::jsonb_to_value
• datafusion::json_types::jsonb_type_name
• datafusion::json_udf::expand_args
• datafusion::register_json_functions
• datafusion::register_streaming_functions
• datafusion::register_streaming_functions_with_watermark
• error::suggest::closest_match
• error::suggest_column
• error::translate_datafusion_error
• error::translate_datafusion_error_with_context
• 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::lookup_table::parse_create_lookup_table
• parser::lookup_table::parse_drop_lookup_table
• parser::lookup_table::validate_properties
• 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
• planner::predicate_split::split_conjunction
• 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

Type Aliases

• Result
• datafusion::StreamSourceRef

Constants

• datafusion::json_types::tags::ARRAY
• datafusion::json_types::tags::BOOL_FALSE
• datafusion::json_types::tags::BOOL_TRUE
• datafusion::json_types::tags::FLOAT64
• datafusion::json_types::tags::INT64
• datafusion::json_types::tags::NULL
• datafusion::json_types::tags::OBJECT
• datafusion::json_types::tags::STRING
• datafusion::watermark_udf::NO_WATERMARK
• error::codes::COLUMN_NOT_FOUND
• error::codes::EXECUTION_FAILED
• error::codes::INTERNAL
• error::codes::JOIN_KEY_MISSING
• error::codes::JOIN_TIME_BOUND_MISSING
• error::codes::JOIN_TYPE_UNSUPPORTED
• error::codes::LATE_DATA_REJECTED
• error::codes::PLANNING_FAILED
• error::codes::TABLE_NOT_FOUND
• error::codes::TEMPORAL_JOIN_NO_PK
• error::codes::TYPE_MISMATCH
• error::codes::UNSUPPORTED_SQL
• error::codes::WATERMARK_REQUIRED
• error::codes::WINDOW_INVALID
• error::codes::WINDOW_SIZE_INVALID
• translator::streaming_ddl::DEFAULT_BUFFER_SIZE
• translator::streaming_ddl::MAX_BUFFER_SIZE
• translator::streaming_ddl::MIN_BUFFER_SIZE