LICENSE
MANIFEST.in
README.md
setup.py
cpcat.egg-info/PKG-INFO
cpcat.egg-info/SOURCES.txt
cpcat.egg-info/dependency_links.txt
cpcat.egg-info/requires.txt
cpcat.egg-info/top_level.txt
deltacat/__init__.py
deltacat/constants.py
deltacat/exceptions.py
deltacat/logs.py
deltacat/benchmarking/__init__.py
deltacat/benchmarking/benchmark_engine.py
deltacat/benchmarking/benchmark_parquet_reads.py
deltacat/benchmarking/benchmark_report.py
deltacat/benchmarking/benchmark_suite.py
deltacat/benchmarking/conftest.py
deltacat/benchmarking/test_benchmark_pipeline.py
deltacat/benchmarking/data/__init__.py
deltacat/benchmarking/data/random_row_generator.py
deltacat/benchmarking/data/row_generator.py
deltacat/catalog/__init__.py
deltacat/catalog/delegate.py
deltacat/catalog/interface.py
deltacat/catalog/default_catalog_impl/__init__.py
deltacat/catalog/iceberg/__init__.py
deltacat/catalog/iceberg/impl.py
deltacat/catalog/iceberg/overrides.py
deltacat/catalog/main/__init__.py
deltacat/catalog/main/impl.py
deltacat/catalog/model/__init__.py
deltacat/catalog/model/catalog.py
deltacat/catalog/model/table_definition.py
deltacat/compute/__init__.py
deltacat/compute/compactor/__init__.py
deltacat/compute/compactor/compaction_session.py
deltacat/compute/compactor/repartition_session.py
deltacat/compute/compactor/model/__init__.py
deltacat/compute/compactor/model/compact_partition_params.py
deltacat/compute/compactor/model/compaction_session_audit_info.py
deltacat/compute/compactor/model/compactor_version.py
deltacat/compute/compactor/model/dedupe_result.py
deltacat/compute/compactor/model/delta_annotated.py
deltacat/compute/compactor/model/delta_file_envelope.py
deltacat/compute/compactor/model/delta_file_locator.py
deltacat/compute/compactor/model/hash_bucket_result.py
deltacat/compute/compactor/model/materialize_result.py
deltacat/compute/compactor/model/primary_key_index.py
deltacat/compute/compactor/model/pyarrow_write_result.py
deltacat/compute/compactor/model/repartition_result.py
deltacat/compute/compactor/model/round_completion_info.py
deltacat/compute/compactor/model/table_object_store.py
deltacat/compute/compactor/steps/__init__.py
deltacat/compute/compactor/steps/dedupe.py
deltacat/compute/compactor/steps/hash_bucket.py
deltacat/compute/compactor/steps/materialize.py
deltacat/compute/compactor/steps/repartition.py
deltacat/compute/compactor/utils/__init__.py
deltacat/compute/compactor/utils/io.py
deltacat/compute/compactor/utils/primary_key_index.py
deltacat/compute/compactor/utils/round_completion_file.py
deltacat/compute/compactor/utils/sort_key.py
deltacat/compute/compactor/utils/system_columns.py
deltacat/compute/compactor_v2/__init__.py
deltacat/compute/compactor_v2/compaction_session.py
deltacat/compute/compactor_v2/constants.py
deltacat/compute/compactor_v2/deletes/__init__.py
deltacat/compute/compactor_v2/deletes/delete_file_envelope.py
deltacat/compute/compactor_v2/deletes/delete_strategy.py
deltacat/compute/compactor_v2/deletes/delete_strategy_equality_delete.py
deltacat/compute/compactor_v2/deletes/model.py
deltacat/compute/compactor_v2/deletes/utils.py
deltacat/compute/compactor_v2/model/__init__.py
deltacat/compute/compactor_v2/model/evaluate_compaction_result.py
deltacat/compute/compactor_v2/model/hash_bucket_input.py
deltacat/compute/compactor_v2/model/hash_bucket_result.py
deltacat/compute/compactor_v2/model/merge_file_group.py
deltacat/compute/compactor_v2/model/merge_input.py
deltacat/compute/compactor_v2/model/merge_result.py
deltacat/compute/compactor_v2/private/__init__.py
deltacat/compute/compactor_v2/private/compaction_utils.py
deltacat/compute/compactor_v2/steps/__init__.py
deltacat/compute/compactor_v2/steps/hash_bucket.py
deltacat/compute/compactor_v2/steps/merge.py
deltacat/compute/compactor_v2/utils/__init__.py
deltacat/compute/compactor_v2/utils/content_type_params.py
deltacat/compute/compactor_v2/utils/dedupe.py
deltacat/compute/compactor_v2/utils/delta.py
deltacat/compute/compactor_v2/utils/io.py
deltacat/compute/compactor_v2/utils/merge.py
deltacat/compute/compactor_v2/utils/primary_key_index.py
deltacat/compute/compactor_v2/utils/task_options.py
deltacat/compute/converter/__init__.py
deltacat/compute/converter/constants.py
deltacat/compute/converter/converter_session.py
deltacat/compute/converter/model/__init__.py
deltacat/compute/converter/model/convert_input.py
deltacat/compute/converter/model/converter_session_params.py
deltacat/compute/converter/pyiceberg/__init__.py
deltacat/compute/converter/pyiceberg/catalog.py
deltacat/compute/converter/pyiceberg/overrides.py
deltacat/compute/converter/pyiceberg/replace_snapshot.py
deltacat/compute/converter/steps/__init__.py
deltacat/compute/converter/steps/convert.py
deltacat/compute/converter/utils/__init__.py
deltacat/compute/converter/utils/convert_task_options.py
deltacat/compute/converter/utils/converter_session_utils.py
deltacat/compute/converter/utils/iceberg_columns.py
deltacat/compute/converter/utils/s3u.py
deltacat/compute/merge_on_read/__init__.py
deltacat/compute/merge_on_read/daft.py
deltacat/compute/merge_on_read/model/__init__.py
deltacat/compute/merge_on_read/model/merge_on_read_params.py
deltacat/compute/merge_on_read/utils/__init__.py
deltacat/compute/merge_on_read/utils/delta.py
deltacat/compute/resource_estimation/__init__.py
deltacat/compute/resource_estimation/delta.py
deltacat/compute/resource_estimation/manifest.py
deltacat/compute/resource_estimation/model.py
deltacat/compute/resource_estimation/parquet.py
deltacat/compute/stats/__init__.py
deltacat/compute/stats/types.py
deltacat/compute/stats/models/__init__.py
deltacat/compute/stats/models/delta_column_stats.py
deltacat/compute/stats/models/delta_stats.py
deltacat/compute/stats/models/delta_stats_cache_result.py
deltacat/compute/stats/models/manifest_entry_stats.py
deltacat/compute/stats/models/stats_result.py
deltacat/examples/__init__.py
deltacat/examples/basic_logging.py
deltacat/examples/hello_world.py
deltacat/examples/common/__init__.py
deltacat/examples/common/fixtures.py
deltacat/examples/iceberg/__init__.py
deltacat/examples/iceberg/iceberg_bucket_writer.py
deltacat/examples/iceberg/iceberg_reader.py
deltacat/io/__init__.py
deltacat/io/file_object_store.py
deltacat/io/memcached_object_store.py
deltacat/io/object_store.py
deltacat/io/ray_plasma_object_store.py
deltacat/io/redis_object_store.py
deltacat/io/s3_object_store.py
deltacat/storage/__init__.py
deltacat/storage/interface.py
deltacat/storage/iceberg/__init__.py
deltacat/storage/iceberg/impl.py
deltacat/storage/iceberg/model.py
deltacat/storage/main/__init__.py
deltacat/storage/main/impl.py
deltacat/storage/model/__init__.py
deltacat/storage/model/delta.py
deltacat/storage/model/interop.py
deltacat/storage/model/list_result.py
deltacat/storage/model/locator.py
deltacat/storage/model/manifest.py
deltacat/storage/model/metafile.py
deltacat/storage/model/namespace.py
deltacat/storage/model/partition.py
deltacat/storage/model/schema.py
deltacat/storage/model/shard.py
deltacat/storage/model/sort_key.py
deltacat/storage/model/stream.py
deltacat/storage/model/table.py
deltacat/storage/model/table_version.py
deltacat/storage/model/transaction.py
deltacat/storage/model/transform.py
deltacat/storage/model/types.py
deltacat/storage/rivulet/__init__.py
deltacat/storage/rivulet/dataset.py
deltacat/storage/rivulet/dataset_executor.py
deltacat/storage/rivulet/logical_plan.py
deltacat/storage/rivulet/serializer.py
deltacat/storage/rivulet/serializer_factory.py
deltacat/storage/rivulet/arrow/__init__.py
deltacat/storage/rivulet/arrow/serializer.py
deltacat/storage/rivulet/feather/__init__.py
deltacat/storage/rivulet/feather/file_reader.py
deltacat/storage/rivulet/feather/serializer.py
deltacat/storage/rivulet/fs/__init__.py
deltacat/storage/rivulet/fs/file_provider.py
deltacat/storage/rivulet/fs/file_store.py
deltacat/storage/rivulet/fs/input_file.py
deltacat/storage/rivulet/fs/output_file.py
deltacat/storage/rivulet/metastore/__init__.py
deltacat/storage/rivulet/metastore/json_sst.py
deltacat/storage/rivulet/metastore/manifest.py
deltacat/storage/rivulet/metastore/sst.py
deltacat/storage/rivulet/metastore/sst_interval_tree.py
deltacat/storage/rivulet/mvp/Table.py
deltacat/storage/rivulet/mvp/__init__.py
deltacat/storage/rivulet/parquet/__init__.py
deltacat/storage/rivulet/parquet/data_reader.py
deltacat/storage/rivulet/parquet/file_reader.py
deltacat/storage/rivulet/parquet/serializer.py
deltacat/storage/rivulet/reader/__init__.py
deltacat/storage/rivulet/reader/block_scanner.py
deltacat/storage/rivulet/reader/data_reader.py
deltacat/storage/rivulet/reader/data_scan.py
deltacat/storage/rivulet/reader/dataset_metastore.py
deltacat/storage/rivulet/reader/dataset_reader.py
deltacat/storage/rivulet/reader/pyarrow_data_reader.py
deltacat/storage/rivulet/reader/query_expression.py
deltacat/storage/rivulet/reader/reader_type_registrar.py
deltacat/storage/rivulet/schema/__init__.py
deltacat/storage/rivulet/schema/datatype.py
deltacat/storage/rivulet/schema/schema.py
deltacat/storage/rivulet/writer/__init__.py
deltacat/storage/rivulet/writer/dataset_writer.py
deltacat/storage/rivulet/writer/memtable_dataset_writer.py
deltacat/tests/__init__.py
deltacat/tests/test_exceptions.py
deltacat/tests/test_logs.py
deltacat/tests/aws/__init__.py
deltacat/tests/aws/test_clients.py
deltacat/tests/aws/test_s3u.py
deltacat/tests/catalog/__init__.py
deltacat/tests/catalog/test_default_catalog_impl.py
deltacat/tests/compute/__init__.py
deltacat/tests/compute/compact_partition_multiple_rounds_test_cases.py
deltacat/tests/compute/compact_partition_rebase_test_cases.py
deltacat/tests/compute/compact_partition_rebase_then_incremental_test_cases.py
deltacat/tests/compute/compact_partition_test_cases.py
deltacat/tests/compute/test_compact_partition_incremental.py
deltacat/tests/compute/test_compact_partition_multiple_rounds.py
deltacat/tests/compute/test_compact_partition_params.py
deltacat/tests/compute/test_compact_partition_rebase.py
deltacat/tests/compute/test_compact_partition_rebase_then_incremental.py
deltacat/tests/compute/test_util_common.py
deltacat/tests/compute/test_util_constant.py
deltacat/tests/compute/test_util_create_table_deltas_repo.py
deltacat/tests/compute/compactor/__init__.py
deltacat/tests/compute/compactor/steps/__init__.py
deltacat/tests/compute/compactor/steps/test_repartition.py
deltacat/tests/compute/compactor/utils/__init__.py
deltacat/tests/compute/compactor/utils/test_io.py
deltacat/tests/compute/compactor/utils/test_round_completion_file.py
deltacat/tests/compute/compactor_v2/__init__.py
deltacat/tests/compute/compactor_v2/test_compaction_session.py
deltacat/tests/compute/compactor_v2/test_hashlib.py
deltacat/tests/compute/compactor_v2/utils/__init__.py
deltacat/tests/compute/compactor_v2/utils/test_task_options.py
deltacat/tests/compute/resource_estimation/__init__.py
deltacat/tests/compute/resource_estimation/test_delta.py
deltacat/tests/compute/resource_estimation/test_manifest.py
deltacat/tests/compute/resource_estimation/data/__init__.py
deltacat/tests/io/__init__.py
deltacat/tests/io/test_cloudpickle_bug_fix.py
deltacat/tests/io/test_file_object_store.py
deltacat/tests/io/test_memcached_object_store.py
deltacat/tests/io/test_ray_plasma_object_store.py
deltacat/tests/io/test_redis_object_store.py
deltacat/tests/io/test_s3_object_store.py
deltacat/tests/local_deltacat_storage/__init__.py
deltacat/tests/local_deltacat_storage/exceptions.py
deltacat/tests/storage/__init__.py
deltacat/tests/storage/conftest.py
deltacat/tests/storage/main/__init__.py
deltacat/tests/storage/main/test_main_storage.py
deltacat/tests/storage/model/__init__.py
deltacat/tests/storage/model/test_delete_parameters.py
deltacat/tests/storage/model/test_metafile_io.py
deltacat/tests/storage/model/test_shard.py
deltacat/tests/storage/rivulet/__init__.py
deltacat/tests/storage/rivulet/conftest.py
deltacat/tests/storage/rivulet/test_dataset.py
deltacat/tests/storage/rivulet/test_manifest.py
deltacat/tests/storage/rivulet/test_sst_interval_tree.py
deltacat/tests/storage/rivulet/test_utils.py
deltacat/tests/storage/rivulet/fs/__init__.py
deltacat/tests/storage/rivulet/fs/test_file_location_provider.py
deltacat/tests/storage/rivulet/fs/test_file_store.py
deltacat/tests/storage/rivulet/schema/__init__.py
deltacat/tests/storage/rivulet/schema/test_schema.py
deltacat/tests/storage/rivulet/writer/__init__.py
deltacat/tests/storage/rivulet/writer/test_dataset_write_then_read.py
deltacat/tests/storage/rivulet/writer/test_dataset_writer.py
deltacat/tests/storage/rivulet/writer/test_memtable_dataset_writer.py
deltacat/tests/test_utils/__init__.py
deltacat/tests/test_utils/constants.py
deltacat/tests/test_utils/filesystem.py
deltacat/tests/test_utils/message_pack_utils.py
deltacat/tests/test_utils/pyarrow.py
deltacat/tests/test_utils/storage.py
deltacat/tests/test_utils/utils.py
deltacat/tests/utils/__init__.py
deltacat/tests/utils/test_cloudpickle.py
deltacat/tests/utils/test_daft.py
deltacat/tests/utils/test_metrics.py
deltacat/tests/utils/test_placement.py
deltacat/tests/utils/test_pyarrow.py
deltacat/tests/utils/test_record_batch_tables.py
deltacat/tests/utils/test_resources.py
deltacat/tests/utils/data/__init__.py
deltacat/tests/utils/ray_utils/__init__.py
deltacat/tests/utils/ray_utils/test_concurrency.py
deltacat/tests/utils/ray_utils/test_dataset.py
deltacat/types/__init__.py
deltacat/types/media.py
deltacat/types/partial_download.py
deltacat/types/tables.py
deltacat/utils/__init__.py
deltacat/utils/arguments.py
deltacat/utils/cloudpickle.py
deltacat/utils/common.py
deltacat/utils/daft.py
deltacat/utils/export.py
deltacat/utils/filesystem.py
deltacat/utils/metrics.py
deltacat/utils/numpy.py
deltacat/utils/pandas.py
deltacat/utils/performance.py
deltacat/utils/placement.py
deltacat/utils/pyarrow.py
deltacat/utils/resources.py
deltacat/utils/s3fs.py
deltacat/utils/schema.py
deltacat/utils/ray_utils/__init__.py
deltacat/utils/ray_utils/collections.py
deltacat/utils/ray_utils/concurrency.py
deltacat/utils/ray_utils/dataset.py
deltacat/utils/ray_utils/performance.py
deltacat/utils/ray_utils/runtime.py