List of all items

Structs

• CsvReaderOptions
• CsvWriterOptions
• OperationRegistry
• ParquetReaderOptions
• ParquetWriterOptions
• SqlDataFrame
• SqlEngine
• SqlExecutionStats
• SqlPlan
• TaggedQueryResult
• catalog::CatalogField
• catalog::ColumnStatistics
• catalog::InMemoryCatalog
• catalog::InMemorySchemaRegistry
• catalog::TableMetadata
• catalog::TableSchema
• catalog::datafusion_bridge::DataFusionCatalogBridge
• catalog::iceberg_rest::GenericRestCatalog
• catalog::iceberg_rest::IcebergTableId
• catalog::iceberg_rest::LoadedIcebergTable
• catalog::iceberg_rest::RestCatalogConfig
• cep_sql::MatchRecognizeStatement
• connector_table::ConnectorTableFactory
• create_function_ddl::ClosureTableUdf
• create_function_ddl::ColumnDef
• create_function_ddl::CreateFunctionDdl
• create_function_ddl::FunctionArgDef
• create_function_ddl::SqlBodyTableUdf
• grammar::FeatureEntry
• incremental_view::IncrementalViewEntry
• incremental_view::IncrementalViewRegistry
• incremental_view::LatenessAnnotation
• lakehouse::AsOfTableRef
• lakehouse::MergeResult
• lakehouse::MergeTargetUnsupportedError
• live_table::LiveTableRegistry
• pipeline_ddl::ConnectorSpec
• pipeline_ddl::PipelineRegistry
• pipeline_ddl::SinkSpec
• pivot_sql::PivotClause
• pivot_sql::UnpivotClause
• recursive_cte::RecursiveCteResult
• recursive_cte::RecursiveCteStatement
• sqlstate::SqlStateError
• streaming::ChannelPartitionStream
• streaming::ContinuousTableInput
• streaming_window_plan::StreamingWindowPlan
• subquery::DetectedSubquery

Enums

• GroupingMode
• SqlError
• catalog::CatalogError
• catalog::FieldType
• grammar::FeatureStatus
• incremental_view::IncrementalViewStatement
• introspection_sql::ExplainSqlMode
• introspection_sql::IntrospectionStatement
• live_table::LiveTableStatement
• pipeline_ddl::PipelineStatement
• pipeline_ddl::SourceSpec
• streaming::ContinuousInputError
• streaming_tvf::WindowTvf
• subquery::SubqueryKind

Traits

• KrishivDataFrameOps
• catalog::CatalogProvider
• catalog::SchemaRegistry
• catalog::TableProvider
• catalog::iceberg_rest::IcebergCatalogClient

Functions

• analyze::analyze_batch
• analyze::analyze_batch_per_column
• analyze::analyze_record_batches
• batch_size_from_env
• cep_sql::execute_match_recognize
• cep_sql::execute_streaming_match_recognize
• cep_sql::parse_match_recognize
• cep_sql::plan_match_recognize
• connector_table::connector_config_from_ddl
• connector_table::register_connector_table_factories
• connector_table::shared_connector_registry
• create_function_ddl::is_create_function_returns_table
• create_function_ddl::parse_create_function
• default_parallelism_from_env
• explain_sql
• explain_sql_optimized
• explain_sql_with_cost
• grammar::feature_matrix
• grammar::features_by_status
• grammar::features_for_category
• incremental_view::execute_incremental_view_ddl
• incremental_view::parse_incremental_view_statement
• introspection_sql::describe_table
• introspection_sql::explain_query
• introspection_sql::explain_result_batch
• introspection_sql::parse_introspection_statement
• kafka_table::create_kafka_streaming_table
• lakehouse::apply_as_of_refs
• lakehouse::execute_merge_sql
• lakehouse::preprocess_as_of_sql
• lakehouse::register_delta_uri
• lakehouse::register_hudi_uri
• lakehouse::register_scan_batches
• live_table::execute_live_table_ddl
• live_table::parse_live_table_statement
• live_table::plan_live_table
• parse_public_expression
• pipeline_ddl::execute_pipeline_ddl
• pipeline_ddl::parse_pipeline_statement
• pivot_sql::contains_pivot
• pivot_sql::contains_unpivot
• pivot_sql::parse_pivot
• pivot_sql::parse_unpivot
• pivot_sql::rewrite_pivot
• pivot_sql::rewrite_pivot_unpivot
• pivot_sql::rewrite_unpivot
• plan_sql
• pretty_batches
• query_memory_limit_from_env
• recursive_cte::build_recursive_cte_op
• recursive_cte::execute_recursive_cte
• recursive_cte::parse_recursive_cte
• referenced_table_names
• resolve_query_memory_limit_bytes
• resolve_streaming_match_recognize_limit
• spark_sql_ext::contains_describe_extended
• spark_sql_ext::contains_lateral_view
• spark_sql_ext::contains_show_tblproperties
• spark_sql_ext::contains_tablesample
• spark_sql_ext::contains_transform
• spark_sql_ext::preprocess_spark_sql
• spark_sql_ext::rewrite_describe_extended
• spark_sql_ext::rewrite_lateral_view
• spark_sql_ext::rewrite_show_tblproperties
• spark_sql_ext::rewrite_tablesample
• spark_sql_ext::rewrite_transform
• sqlstate::sqlstate_for
• streaming::create_continuous_table
• streaming::create_continuous_table_with_capacity
• streaming_match_recognize_limit_from_env
• streaming_tvf::find_window_tvf
• streaming_tvf::rewrite_window_tvfs
• streaming_window_plan::compile_streaming_window_sql
• streaming_window_plan::is_windowed_streaming_sql
• subquery::detect_subqueries
• subquery::explain_subqueries
• subquery::validate_no_streaming_subqueries
• unnest_sql::build_unnest_op
• unnest_sql::contains_lateral
• unnest_sql::contains_unnest
• unnest_sql::rewrite_lateral_unnest

Type Aliases

• SqlResult
• SqlStream
• catalog::CatalogResult
• catalog::LakehouseError
• create_function_ddl::UdtfBodyFn

Constants

• analyze::EXACT_NDV_CAP
• recursive_cte::DEFAULT_MAX_ITERATIONS
• sqlstate::DATA_EXCEPTION
• sqlstate::FEATURE_NOT_SUPPORTED
• sqlstate::GENERAL_ERROR
• sqlstate::INSUFFICIENT_PRIVILEGE
• sqlstate::INTERNAL_ERROR
• sqlstate::INVALID_AUTHORIZATION
• sqlstate::QUERY_CANCELLED
• sqlstate::QUERY_TIMEOUT
• sqlstate::SUCCESS
• sqlstate::SYNTAX_ERROR
• sqlstate::SYSTEM_ERROR
• sqlstate::UNDEFINED_TABLE
• streaming::CONTINUOUS_TABLE_CHANNEL_CAPACITY