List of all items

Structs

• CsvReaderOptions
• CsvWriterOptions
• MemoryConsumer
• MemoryReservation
• OperationRegistry
• ParquetReaderOptions
• ParquetWriterOptions
• SqlDataFrame
• SqlEngine
• SqlExecutionStats
• SqlPlan
• SqlStatsHandle
• 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
• coop_amplifiers::CooperativeAmplifiers
• coverage::ChecklistCase
• coverage::CoverageReport
• create_function_ddl::ClosureTableUdf
• create_function_ddl::ColumnDef
• create_function_ddl::CreateFunctionDdl
• create_function_ddl::FunctionArgDef
• create_function_ddl::SqlBodyTableUdf
• distributed_plan::ClusterCapacity
• distributed_plan::DfplanMapRange
• distributed_plan::DfplanTaskSpec
• distributed_plan::DistributedStage
• distributed_plan::DistributedStagePlan
• distributed_plan::KrishivPhysicalCodec
• distributed_plan::ParquetTableSpec
• distributed_plan::ShuffleReadExec
• distributed_plan::StageShuffleOutput
• grace_hash_join::GraceHashJoinExec
• grammar::FeatureEntry
• incremental_view::IncrementalViewEntry
• incremental_view::IncrementalViewRegistry
• incremental_view::LatenessAnnotation
• lakehouse::AsOfTableRef
• lakehouse::MergeResult
• lakehouse::MergeTargetUnsupportedError
• late_materialize::LateMaterializeTopKAggregate
• live_table::LiveTableRegistry
• object_store_registry::LazyCloudObjectStoreRegistry
• pipeline_ddl::ConnectorSpec
• pipeline_ddl::PipelineRegistry
• pipeline_ddl::SinkSpec
• pivot_sql::PivotClause
• pivot_sql::UnpivotClause
• python_udf::PythonWorkerAggregateUdf
• python_udf::PythonWorkerPool
• python_udf::PythonWorkerUdf
• runtime_filter_exec::RuntimeFilterBuildExec
• runtime_filter_exec::RuntimeFilterProbeExec
• scalar_udf::ScalarSqlFunction
• semi_join_reduction::SemiJoinPushdownThroughInnerJoin
• semi_join_reduction::SemiJoinReductionFromSelectiveDimension
• semi_join_reduction::SemiJoinReductionThroughAggregate
• spillable_join::SpillableJoinSelection
• sqlstate::SqlStateError
• statement_completion::UseTarget
• streaming::ChannelPartitionStream
• streaming::ContinuousTableInput
• streaming_table_ddl::StreamingTableDdl
• streaming_window_plan::StreamingWindowPlan
• subquery::DetectedSubquery
• unspillable_headroom::UnspillableHeadroomPool

Enums

• EngineMemory
• GroupingMode
• SqlError
• catalog::CatalogError
• catalog::FieldType
• coverage::Coverage
• grammar::Engine
• grammar::FeatureStatus
• grammar::Placement
• incremental_view::IncrementalViewResult
• 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
• MemoryPool
• RecordBatchStream
• catalog::CatalogProvider
• catalog::SchemaRegistry
• catalog::TableProvider
• catalog::iceberg_rest::IcebergCatalogClient
• distributed_plan::ShufflePartitionReader

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
• cgroup_memory_limit_bytes
• connector_table::connector_config_from_ddl
• connector_table::register_connector_table_factories
• connector_table::shared_connector_registry
• coverage::coverage_report
• create_function_ddl::is_create_function_returns_table
• create_function_ddl::parse_create_function
• default_parallelism_from_env
• distributed_plan::build_distributed_stages
• distributed_plan::build_distributed_stages_with_udf_directives
• distributed_plan::build_stages_for_parquet_query
• distributed_plan::build_stages_for_parquet_tables
• distributed_plan::decode_dfplan_task
• distributed_plan::derive_stage_target_partitions
• distributed_plan::dfplan_body_is_split_safe
• distributed_plan::dfplan_body_partition_spec
• distributed_plan::dfplan_body_with_spec
• distributed_plan::dfplan_task_body
• distributed_plan::dfplan_task_body_for_spec
• distributed_plan::encode_dfplan_bytes
• distributed_plan::execute_dfplan_body
• distributed_plan::fragment_decode_session_context
• distributed_plan::is_dfplan_body
• distributed_plan::parse_dfplan_body
• distributed_plan::planning_session_context
• distributed_plan::planning_session_context_with_join_threshold
• distributed_plan::planning_session_context_with_options
• distributed_plan::redistribute_unsplittable_broadcast_joins
• distributed_plan::register_parquet_table
• distributed_plan::register_python_udf_signatures_and_strip
• distributed_plan::resolve_stage_target_partitions
• distributed_plan::shuffle_stage_key
• distributed_plan::stage_reuse_enabled
• distributed_plan::stage_split_enabled
• explain_sql
• explain_sql_optimized
• explain_sql_with_cost
• grace_hash_join::bucket_count
• grace_hash_join::enabled
• grammar::feature_matrix
• grammar::features_by_status
• grammar::features_for_category
• grammar::generate_honesty_markdown
• grammar::generate_reference_markdown
• 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
• late_materialize::late_materialization_enabled
• 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
• process_query_pool
• python_udf::global_pool
• query_memory_limit_from_env
• referenced_table_names
• resolve_query_memory_limit_bytes
• resolve_streaming_match_recognize_limit
• runtime_filter_exec::enabled
• runtime_filter_exec::filter_schema
• runtime_filters_enabled_from_env
• scalar_udf::expand_scalar_sql_functions
• semi_join_reduction::semi_join_dimension_reduction_enabled
• semi_join_reduction::semi_join_pushdown_enabled
• semi_join_reduction::semi_join_reduction_enabled
• 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
• statement_completion::apply_use
• statement_completion::parse_use
• statement_completion::rewrite_show_databases
• streaming::create_continuous_table
• streaming::create_continuous_table_with_capacity
• streaming_match_recognize_limit_from_env
• streaming_table_ddl::parse_create_streaming_table
• 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
• unspillable_headroom::headroom_bytes
• with_krishiv_optimizer_rules
• with_krishiv_optimizer_rules_with_join_threshold

Type Aliases

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

Statics

• coverage::CHECKLIST

Constants

• analyze::EXACT_NDV_CAP
• coverage::FIXTURE_T
• coverage::FIXTURE_U
• distributed_plan::BROADCAST_JOIN_BYTES_ENV
• distributed_plan::DFPLAN_BODY_PREFIX
• distributed_plan::DIMENSION_REDUCTION_ENV
• distributed_plan::SHUFFLE_FETCH_BUFFER_ENV
• distributed_plan::STAGE_REUSE_ENV
• distributed_plan::STAGE_SPLIT_ENV
• distributed_plan::STAGE_TARGET_PARTITIONS_ENV
• grace_hash_join::GRACE_HASH_JOIN_BUCKETS_ENV
• grace_hash_join::GRACE_HASH_JOIN_ENV
• grammar::EMBEDDED_ONLY_OPERATORS
• late_materialize::LATE_MATERIALIZATION_ENV
• runtime_filter_exec::FILTER_COLUMN
• runtime_filter_exec::RUNTIME_FILTER_ENV
• semi_join_reduction::SEMI_JOIN_DIMENSION_ENV
• semi_join_reduction::SEMI_JOIN_PUSHDOWN_ENV
• semi_join_reduction::SEMI_JOIN_REDUCTION_ENV
• spillable_join::SPILL_JOIN_BUILD_BYTES_ENV
• 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
• unspillable_headroom::DEFAULT_UNSPILLABLE_HEADROOM_DENOMINATOR
• unspillable_headroom::DEFAULT_UNSPILLABLE_HEADROOM_NUMERATOR
• unspillable_headroom::UNSPILLABLE_HEADROOM_PERCENT_ENV