List of all items

Structs

• AddEntityOptions
• AddEntityOutcome
• RunOptions
• ValidateOptions
• checks::CsvRowErrorFormatter
• checks::JsonRowErrorFormatter
• checks::MismatchOutcome
• checks::RowError
• checks::SparseRowErrors
• checks::TextRowErrorFormatter
• checks::UniqueTracker
• config::ArchiveTarget
• config::CatalogDefinition
• config::CatalogResolver
• config::CatalogsConfig
• config::ColumnConfig
• config::ConfigBase
• config::ConfigLocation
• config::DomainConfig
• config::EntityConfig
• config::EntityMetadata
• config::EnvConfig
• config::IcebergPartitionFieldConfig
• config::IcebergSinkTargetConfig
• config::NormalizeColumnsConfig
• config::PolicyConfig
• config::ProjectMetadata
• config::ReportConfig
• config::ResolvedIcebergCatalogTarget
• config::ResolvedPath
• config::RootConfig
• config::SchemaConfig
• config::SchemaMismatchConfig
• config::SinkConfig
• config::SinkOptions
• config::SinkTarget
• config::SourceConfig
• config::SourceOptions
• config::StorageDefinition
• config::StorageResolver
• config::StoragesConfig
• errors::ConfigError
• errors::IoError
• errors::RunError
• errors::StorageError
• io::format::AcceptedWriteMetrics
• io::format::AcceptedWriteOutput
• io::format::FileReadError
• io::format::InputFile
• io::format::RejectedWriteRequest
• io::read::avro::AvroReadError
• io::read::csv::CsvReadPlan
• io::read::json::JsonReadError
• io::read::json_selector::SelectorError
• io::read::xlsx::XlsxReadError
• io::read::xml::XmlReadError
• io::read::xml_selector::SelectorError
• io::storage::CloudClient
• io::storage::core::planner::ObjectRef
• io::storage::core::uri::AdlsLocation
• io::storage::core::uri::BucketLocation
• io::storage::object_store::DeltaStoreConfig
• io::storage::object_store::IcebergStoreConfig
• io::storage::ops::inputs::ResolvedInputs
• io::storage::providers::adls::AdlsClient
• io::storage::providers::gcs::GcsClient
• io::storage::providers::local::LocalClient
• io::storage::providers::local::ResolvedLocalInputs
• io::storage::providers::s3::S3Client
• io::write::accepted::AcceptedWriteRequest
• io::write::accepted::AdapterAcceptedWriter
• io::write::delta::DeltaCommitAddStats
• io::write::delta::DeltaWriteRuntimeOptions
• io::write::parquet::ParquetWriteRuntimeOptions
• io::write::parts::PartFile
• io::write::parts::PartNameAllocator
• io::write::strategy::PartSpec
• io::write::strategy::WriteContext
• report::AcceptedOutputSummary
• report::ColumnSummary
• report::ConfigEcho
• report::EntityEcho
• report::EntitySummary
• report::FileMismatch
• report::FileOutput
• report::FileReport
• report::FileValidation
• report::GitInfo
• report::JsonReportFormatter
• report::MismatchIssue
• report::PolicyEcho
• report::ReportEcho
• report::ReportWriter
• report::ResolvedInputs
• report::ResultsTotals
• report::RuleSummary
• report::RunInfo
• report::RunReport
• report::RunSummaryReport
• report::SinkArchiveEcho
• report::SinkEcho
• report::SinkTargetEcho
• report::SourceEcho
• report::ToolInfo
• report::output::ReportOutput
• run::DryRunEntityPreview
• run::EntityOutcome
• run::RunOutcome
• run::events::NoopObserver
• runtime::DefaultRuntime

Enums

• config::WriteMode
• io::format::FormatKind
• io::format::ReadInput
• io::read::json_selector::SelectorToken
• io::read::json_selector::SelectorValue
• io::read::xml_selector::SelectorToken
• io::storage::core::placement::OutputPlacement
• io::storage::ops::inputs::ResolveInputsMode
• io::storage::providers::local::LocalInputMode
• io::storage::target::Target
• io::write::strategy::PartScope
• report::FileStatus
• report::MismatchAction
• report::ReportError
• report::ResolvedInputMode
• report::RuleName
• report::RunStatus
• report::Severity
• report::SourceReadPlan
• run::events::RunEvent

Traits

• checks::RowErrorFormatter
• io::format::AcceptedSinkAdapter
• io::format::InputAdapter
• io::format::RejectedSinkAdapter
• io::storage::StorageClient
• io::write::accepted::AcceptedWriter
• io::write::strategy::ModeStrategy
• report::ReportFormatter
• run::events::RunObserver
• runtime::Runtime

Functions

• add_entity_to_config
• checks::apply_mismatch_plan
• checks::apply_schema_mismatch
• checks::build_accept_rows
• checks::build_errors_formatted
• checks::build_errors_json
• checks::build_row_masks
• checks::cast_mismatch_counts
• checks::cast_mismatch_errors
• checks::cast_mismatch_errors_sparse
• checks::column_index_map
• checks::normalize::normalize_dataframe_columns
• checks::normalize::normalize_name
• checks::normalize::output_column_mapping
• checks::normalize::rename_output_columns
• checks::normalize::resolve_normalize_strategy
• checks::normalize::resolve_output_columns
• checks::normalize::resolve_source_columns
• checks::normalize::source_column_mapping
• checks::not_null_counts
• checks::not_null_errors
• checks::not_null_errors_sparse
• checks::plan_schema_mismatch
• checks::rejected_error_columns
• checks::resolve_mismatch_columns
• checks::row_error_formatter
• checks::top_level_declared_columns
• checks::unique_counts
• checks::unique_errors
• checks::unique_errors_sparse
• config::resolve_config_location
• config::resolve_local_path
• errors::emit
• io::format::accepted_sink_adapter
• io::format::collect_row_errors
• io::format::ensure_accepted_sink_format
• io::format::ensure_input_format
• io::format::ensure_rejected_sink_format
• io::format::input_adapter
• io::format::rejected_sink_adapter
• io::format::resolve_read_columns
• io::format::sink_options_warning
• io::format::validate_sink_options
• io::read::csv::read_csv_file
• io::read::csv::read_csv_header
• io::read::json_selector::compact_json
• io::read::json_selector::evaluate_selector
• io::read::json_selector::parse_selector
• io::read::json_selector::selector_is_top_level
• io::read::json_selector::selector_tokens_or_error
• io::read::orc::read_orc_df
• io::read::orc::read_orc_schema_names
• io::read::parquet::read_parquet_lazy
• io::read::parquet::read_parquet_schema_names
• io::read::xml_selector::is_top_level_selector
• io::read::xml_selector::parse_selector
• io::storage::core::extensions::glob_patterns_for_format
• io::storage::core::extensions::suffixes_for_format
• io::storage::core::paths::archive_filename_for_run
• io::storage::core::paths::archive_relative_path
• io::storage::core::paths::archive_relative_path_for_run
• io::storage::core::paths::build_output_filename
• io::storage::core::paths::build_part_stem
• io::storage::core::paths::normalize_local_path
• io::storage::core::paths::resolve_archive_key
• io::storage::core::paths::resolve_archive_key_for_run
• io::storage::core::paths::resolve_archive_path
• io::storage::core::paths::resolve_archive_path_for_run
• io::storage::core::paths::resolve_output_dir_key
• io::storage::core::paths::resolve_output_dir_path
• io::storage::core::paths::resolve_output_key
• io::storage::core::paths::resolve_output_path
• io::storage::core::paths::resolve_sibling_key
• io::storage::core::paths::resolve_sibling_path
• io::storage::core::planner::copy_via_temp
• io::storage::core::planner::ensure_parent_dir
• io::storage::core::planner::exists_by_key
• io::storage::core::planner::file_name_from_key
• io::storage::core::planner::file_stem_from_name
• io::storage::core::planner::filter_by_suffixes
• io::storage::core::planner::join_prefix
• io::storage::core::planner::normalize_separators
• io::storage::core::planner::object_ref
• io::storage::core::planner::stable_sort_refs
• io::storage::core::planner::temp_path_for_key
• io::storage::core::uri::format_abfs_uri
• io::storage::core::uri::format_bucket_uri
• io::storage::core::uri::parse_abfs_uri
• io::storage::core::uri::parse_bucket_uri
• io::storage::core::validation::require_field
• io::storage::object_store::delta_store_config
• io::storage::object_store::iceberg_store_config
• io::storage::ops::archive::archive_input_file
• io::storage::ops::archive_input
• io::storage::ops::inputs::resolve_inputs
• io::storage::ops::output::write_output
• io::storage::ops::resolve_inputs
• io::storage::providers::adls::format_abfs_uri
• io::storage::providers::adls::parse_adls_uri
• io::storage::providers::gcs::format_gcs_uri
• io::storage::providers::gcs::parse_gcs_uri
• io::storage::providers::local::resolve_local_inputs
• io::storage::providers::s3::filter_keys_by_suffixes
• io::storage::providers::s3::format_s3_uri
• io::storage::providers::s3::parse_s3_uri
• io::write::accepted::write_with_adapter
• io::write::csv::write_rejected_csv
• io::write::delta::delta_write_runtime_options
• io::write::delta::write_delta_table
• io::write::iceberg::write_iceberg_table
• io::write::metrics::default_small_file_threshold_bytes
• io::write::metrics::summarize_written_file_sizes
• io::write::parquet::parquet_write_runtime_options
• io::write::parquet::write_parquet_to_path
• io::write::parts::append_part_filename
• io::write::parts::clear_local_part_files
• io::write::parts::is_part_filename
• io::write::parts::is_part_key
• io::write::parts::list_local_part_files
• io::write::parts::list_local_part_paths
• io::write::parts::next_local_part_filename
• io::write::parts::next_local_part_index
• io::write::parts::part_filename
• io::write::strategy::accepted_parquet_spec
• io::write::strategy::append_part_allocator
• io::write::strategy::ensure_mode_supported
• io::write::strategy::overwrite_part_allocator
• io::write::strategy::rejected_csv_spec
• io::write::strategy::strategy_for
• io::write::write_error_report
• io::write::write_rejected_raw
• load_config
• manifest::build_common_manifest_json
• report::build::entity_metadata_json
• report::build::project_metadata_json
• report::build::source_options_json
• report::build::summarize_validation
• report::build::summarize_validation_sparse
• report::compute_run_outcome
• report::now_rfc3339
• report::output::write_entity_report
• report::output::write_summary_report
• report::run_id_from_timestamp
• run::events::default_observer
• run::events::event_time_ms
• run::events::is_observer_set
• run::events::set_observer
• run::run
• run::run_with_base
• run::run_with_runtime
• validate
• validate_config_for_tests
• validate_with_base
• warnings::emit
• warnings::emit_once

Type Aliases

• FloeResult
• checks::ColumnIndex
• io::storage::providers::adls::AdlsLocation
• io::storage::providers::gcs::GcsLocation
• io::storage::providers::s3::S3Location

Constants

• io::write::metrics::BYTES_PER_MIB
• io::write::metrics::DEFAULT_SMALL_FILE_THRESHOLD_BYTES