lix 0.17.1

mod bind;
mod branch_ref;
mod branch_scope;
mod catalog;
mod change_materialization;
mod checkpoint_function;
mod context;
mod dialect;
mod dml;
mod error;
mod exec;
mod file_view;
mod information_schema;
mod parse;
mod plan;
mod planning_cache;
mod predicate_typecheck;
mod providers;
#[cfg(test)]
pub(crate) use providers::take_mainline_work;
#[cfg(test)]
pub(crate) use providers::{arm_state_at_traversal_probe, take_state_at_traversal_probe};
mod read_only;
mod result_metadata;
mod row_batch;
mod row_columnar_layout;
mod row_projection;
mod runtime;
// Host-side script inspection; execution remains the native single-statement path.
pub(crate) mod script;
mod session;
#[cfg(test)]
mod test_support;
mod udfs;
mod value_contract;
mod write_normalization;

#[cfg(feature = "storage-benches")]
pub(crate) use error::datafusion_error_to_lix_error;

#[cfg(test)]
pub(crate) use bind::bind_statement;
pub(crate) use bind::{
    BoundStatementRoute, bind_read_statement, bind_statement_route, bind_statement_with_catalog,
    statement_has_durable_runtime_function,
};
pub(crate) use catalog::{
    PublicCatalog, PublicSurfaceKind, SchemaColumnType, SchemaIndexedColumn, SchemaSurfaceSpec,
    derive_schema_surface_spec_from_schema, row_visible_fields,
};
pub(crate) use checkpoint_function::{CheckpointFunctionPlan, checkpoint_function_plan};
pub(crate) use context::WriteContextLiveness;
pub(crate) use context::{
    ChangelogQuerySource, DiffCommand, DiffCommandOutcome, DiffCommandSelection,
    SqlChangelogQuerySource, SqlExecutionContext, SqlWriteContext, SqlWriteExecutionContext,
    WriteAccess, WriteContextBranchRefReader, WriteContextHotStateReader,
};
pub(crate) use exec::bound_public_write::PreparedPathValueReplacementProgram;
#[cfg(feature = "storage-benches")]
pub(crate) use exec::{
    BatchRowCursor, execute_read_statement_in_session_with_batch_stream,
    execute_read_statement_in_session_with_collected_batches,
};
pub(crate) use exec::{SessionReadResult, SessionReadSqlResult, SqlWriteResult};
#[allow(unused_imports)]
pub(crate) use exec::{
    SqlLogicalPlan, append_path_value_replacement_snapshot,
    append_path_value_replacement_snapshot_text, create_write_logical_plan_from_template,
    create_write_plan_template_from_parsed, diff_command_query,
    execute_read_statement_in_session_from_parsed, execute_read_statement_in_session_with_result,
    execute_transaction_read_statement_from_parsed, execute_write_logical_plan_parameter_batch,
    execute_write_logical_plan_result_with_metadata, execute_write_logical_plan_value_batch,
    parameter_record_batch, parameter_row, prepare_path_value_replacement_program,
    prepare_path_value_replacement_row, prepare_read_session, prepare_read_session_at_head,
    query_result_from_batches, query_values_from_batches,
    write_plan_requires_post_stage_returning_checkpoint,
};
#[cfg(test)]
pub(crate) use exec::{
    WriteExecutorMode, WriteExecutorPath, create_write_logical_plan, execute_write_logical_plan,
    execute_write_logical_plan_with_mode, execute_write_logical_plan_with_mode_and_trace,
    execute_write_logical_plan_with_mode_and_trace_result,
    execute_write_logical_plan_with_mode_result, take_certified_generation_identity_replacements,
    take_certified_replacement_parameter_batch_executions,
    take_certified_row_insert_batch_executions,
    take_certified_row_insert_parameter_batch_executions,
    take_certified_single_path_value_replacements, take_row_update_parameter_batch_executions,
};
pub(crate) use file_view::{
    SessionFileViewKey, SessionFileViewMutation, SessionFileViews, SessionPluginFileView,
};
pub(crate) use parse::{object_name_is_public_function, parse_statement};
pub(crate) use plan::plan_write;
pub(crate) use planning_cache::{
    CachedPhysicalRead, CachedReadPlan, CachedScanRequest, CachedUpdateLiteralShape,
    PhysicalReadPlanCacheKey, PooledReadSession, SqlPlanningCache,
};
pub(crate) use providers::{
    ExactLixFileReadColumn, ExactLixFileReadSelector, FastLixFilePathWriteConflict,
    execute_exact_lix_directory_root_listing, execute_exact_lix_file_batch_read,
    execute_exact_lix_file_id_manifest_batch_read, execute_exact_lix_file_read,
    execute_exact_lix_file_root_listing, execute_exact_schema_batch_read,
    execute_exact_schema_point_read, execute_fast_lix_file_path_writes,
    execute_fast_lix_file_prepared_path_write,
};
pub(crate) use result_metadata::result_column_type;
pub(crate) use row_batch::{CurrentRowSnapshotReader, RowSnapshotReader};
pub(crate) use row_columnar_layout::{
    LOW_CARDINALITY_CLUSTER_MAX_VALUES, ROW_COLUMNAR_BASE_COORDINATES_METADATA_KEY,
    ROW_COLUMNAR_IDENTITY_FIELD, ROW_COLUMNAR_LAYOUT_FINGERPRINT_METADATA_KEY,
    ROW_COLUMNAR_LOSSLESS_SNAPSHOT_METADATA_KEY, encode_unclustered_registered_row_groups,
};
#[cfg(test)]
pub(crate) use row_columnar_layout::{RowColumnarRowRef, encode_registered_row_groups};
pub(crate) use row_projection::RowProjectionDecoder;
mod aggregate_statistics;

pub(crate) use plan::read::execute_native_read;
#[cfg(test)]
pub(crate) use plan::read::statement::ExactFilesystemRead;
#[cfg(any(test, feature = "storage-benches"))]
pub(crate) use plan::read::statement::exact_filesystem_read_route;
pub(crate) use plan::read::statement::{
    StatementReadPlan, is_acknowledgeable_file_content_read,
    late_materialized_lix_file_content_read, plan_read_statement,
};

pub(crate) use providers::{
    prepare_native_diff_interest, prepare_native_file_content_interest,
    prepare_native_file_metadata_interest,
};