LICENSE
MANIFEST.in
NOTICE
README.md
setup.py
dev/requirements.txt
pypaimon/__init__.py
pypaimon.egg-info/PKG-INFO
pypaimon.egg-info/SOURCES.txt
pypaimon.egg-info/dependency_links.txt
pypaimon.egg-info/entry_points.txt
pypaimon.egg-info/requires.txt
pypaimon.egg-info/top_level.txt
pypaimon/acceptance/__init__.py
pypaimon/acceptance/incremental_diff_acceptance_test.py
pypaimon/api/__init__.py
pypaimon/api/api_request.py
pypaimon/api/api_response.py
pypaimon/api/client.py
pypaimon/api/resource_paths.py
pypaimon/api/rest_api.py
pypaimon/api/rest_exception.py
pypaimon/api/rest_util.py
pypaimon/api/token_loader.py
pypaimon/api/typedef.py
pypaimon/api/auth/__init__.py
pypaimon/api/auth/base.py
pypaimon/api/auth/bearer.py
pypaimon/api/auth/dlf_provider.py
pypaimon/api/auth/dlf_signer.py
pypaimon/api/auth/factory.py
pypaimon/branch/__init__.py
pypaimon/branch/branch_manager.py
pypaimon/branch/catalog_branch_manager.py
pypaimon/branch/filesystem_branch_manager.py
pypaimon/catalog/__init__.py
pypaimon/catalog/catalog.py
pypaimon/catalog/catalog_context.py
pypaimon/catalog/catalog_environment.py
pypaimon/catalog/catalog_exception.py
pypaimon/catalog/catalog_factory.py
pypaimon/catalog/catalog_loader.py
pypaimon/catalog/database.py
pypaimon/catalog/filesystem_catalog.py
pypaimon/catalog/filesystem_catalog_loader.py
pypaimon/catalog/table_rollback.py
pypaimon/catalog/rest/__init__.py
pypaimon/catalog/rest/fuse_support.py
pypaimon/catalog/rest/property_change.py
pypaimon/catalog/rest/rest_catalog.py
pypaimon/catalog/rest/rest_catalog_loader.py
pypaimon/catalog/rest/rest_token.py
pypaimon/catalog/rest/rest_token_file_io.py
pypaimon/catalog/rest/table_metadata.py
pypaimon/changelog/__init__.py
pypaimon/changelog/changelog.py
pypaimon/changelog/changelog_manager.py
pypaimon/cli/__init__.py
pypaimon/cli/cli.py
pypaimon/cli/cli_catalog.py
pypaimon/cli/cli_db.py
pypaimon/cli/cli_table.py
pypaimon/cli/where_parser.py
pypaimon/common/__init__.py
pypaimon/common/delta_varint_compressor.py
pypaimon/common/external_path_provider.py
pypaimon/common/file_io.py
pypaimon/common/identifier.py
pypaimon/common/json_util.py
pypaimon/common/memory_size.py
pypaimon/common/predicate.py
pypaimon/common/predicate_builder.py
pypaimon/common/time_utils.py
pypaimon/common/uri_reader.py
pypaimon/common/options/__init__.py
pypaimon/common/options/config.py
pypaimon/common/options/config_option.py
pypaimon/common/options/config_options.py
pypaimon/common/options/core_options.py
pypaimon/common/options/options.py
pypaimon/common/options/options_utils.py
pypaimon/consumer/__init__.py
pypaimon/consumer/consumer.py
pypaimon/consumer/consumer_manager.py
pypaimon/data/__init__.py
pypaimon/data/timestamp.py
pypaimon/deletionvectors/__init__.py
pypaimon/deletionvectors/apply_deletion_vector_reader.py
pypaimon/deletionvectors/bitmap_deletion_vector.py
pypaimon/deletionvectors/deletion_vector.py
pypaimon/filesystem/__init__.py
pypaimon/filesystem/jindo_file_system_handler.py
pypaimon/filesystem/local.py
pypaimon/filesystem/local_file_io.py
pypaimon/filesystem/pvfs.py
pypaimon/filesystem/pyarrow_file_io.py
pypaimon/globalindex/__init__.py
pypaimon/globalindex/global_index_evaluator.py
pypaimon/globalindex/global_index_meta.py
pypaimon/globalindex/global_index_reader.py
pypaimon/globalindex/global_index_result.py
pypaimon/globalindex/global_index_scanner.py
pypaimon/globalindex/indexed_split.py
pypaimon/globalindex/vector_search.py
pypaimon/globalindex/vector_search_result.py
pypaimon/globalindex/btree/__init__.py
pypaimon/globalindex/btree/block_aligned_type.py
pypaimon/globalindex/btree/block_entry.py
pypaimon/globalindex/btree/block_handle.py
pypaimon/globalindex/btree/block_reader.py
pypaimon/globalindex/btree/btree_file_footer.py
pypaimon/globalindex/btree/btree_index_meta.py
pypaimon/globalindex/btree/btree_index_reader.py
pypaimon/globalindex/btree/key_serializer.py
pypaimon/globalindex/btree/memory_slice_input.py
pypaimon/globalindex/btree/sst_file_reader.py
pypaimon/index/__init__.py
pypaimon/index/deletion_vector_meta.py
pypaimon/index/index_file_handler.py
pypaimon/index/index_file_meta.py
pypaimon/manifest/__init__.py
pypaimon/manifest/fastavro_py36_compat.py
pypaimon/manifest/index_manifest_entry.py
pypaimon/manifest/index_manifest_file.py
pypaimon/manifest/manifest_file_manager.py
pypaimon/manifest/manifest_list_manager.py
pypaimon/manifest/simple_stats_evolution.py
pypaimon/manifest/simple_stats_evolutions.py
pypaimon/manifest/schema/__init__.py
pypaimon/manifest/schema/data_file_meta.py
pypaimon/manifest/schema/file_entry.py
pypaimon/manifest/schema/manifest_entry.py
pypaimon/manifest/schema/manifest_file_meta.py
pypaimon/manifest/schema/simple_stats.py
pypaimon/read/__init__.py
pypaimon/read/interval_partition.py
pypaimon/read/partition_info.py
pypaimon/read/plan.py
pypaimon/read/push_down_utils.py
pypaimon/read/read_builder.py
pypaimon/read/sliced_split.py
pypaimon/read/split.py
pypaimon/read/split_read.py
pypaimon/read/stream_read_builder.py
pypaimon/read/streaming_table_scan.py
pypaimon/read/table_read.py
pypaimon/read/table_scan.py
pypaimon/read/datasource/__init__.py
pypaimon/read/datasource/ray_datasource.py
pypaimon/read/datasource/torch_dataset.py
pypaimon/read/reader/__init__.py
pypaimon/read/reader/blob_descriptor_convert_reader.py
pypaimon/read/reader/concat_batch_reader.py
pypaimon/read/reader/concat_record_reader.py
pypaimon/read/reader/data_file_batch_reader.py
pypaimon/read/reader/drop_delete_reader.py
pypaimon/read/reader/empty_record_reader.py
pypaimon/read/reader/field_bunch.py
pypaimon/read/reader/filter_record_batch_reader.py
pypaimon/read/reader/filter_record_reader.py
pypaimon/read/reader/format_avro_reader.py
pypaimon/read/reader/format_blob_reader.py
pypaimon/read/reader/format_lance_reader.py
pypaimon/read/reader/format_pyarrow_reader.py
pypaimon/read/reader/key_value_unwrap_reader.py
pypaimon/read/reader/key_value_wrap_reader.py
pypaimon/read/reader/lance_utils.py
pypaimon/read/reader/row_range_filter_record_reader.py
pypaimon/read/reader/shard_batch_reader.py
pypaimon/read/reader/sort_merge_reader.py
pypaimon/read/reader/iface/__init__.py
pypaimon/read/reader/iface/record_batch_reader.py
pypaimon/read/reader/iface/record_iterator.py
pypaimon/read/reader/iface/record_reader.py
pypaimon/read/scanner/__init__.py
pypaimon/read/scanner/append_table_split_generator.py
pypaimon/read/scanner/changelog_follow_up_scanner.py
pypaimon/read/scanner/data_evolution_split_generator.py
pypaimon/read/scanner/delta_follow_up_scanner.py
pypaimon/read/scanner/file_scanner.py
pypaimon/read/scanner/follow_up_scanner.py
pypaimon/read/scanner/incremental_diff_scanner.py
pypaimon/read/scanner/primary_key_table_split_generator.py
pypaimon/read/scanner/split_generator.py
pypaimon/sample/__init__.py
pypaimon/sample/oss_read_and_write.py
pypaimon/sample/rest_catalog_blob_as_descriptor_sample.py
pypaimon/sample/rest_catalog_ray_data_sample.py
pypaimon/sample/rest_catalog_ray_lance_sample.py
pypaimon/sample/rest_catalog_ray_sink_sample.py
pypaimon/sample/rest_catalog_read_write_sample.py
pypaimon/sample/data/__init__.py
pypaimon/schema/__init__.py
pypaimon/schema/data_types.py
pypaimon/schema/schema.py
pypaimon/schema/schema_change.py
pypaimon/schema/schema_manager.py
pypaimon/schema/table_schema.py
pypaimon/snapshot/__init__.py
pypaimon/snapshot/catalog_snapshot_commit.py
pypaimon/snapshot/renaming_snapshot_commit.py
pypaimon/snapshot/snapshot.py
pypaimon/snapshot/snapshot_commit.py
pypaimon/snapshot/snapshot_loader.py
pypaimon/snapshot/snapshot_manager.py
pypaimon/snapshot/table_snapshot.py
pypaimon/snapshot/time_travel_util.py
pypaimon/table/__init__.py
pypaimon/table/bucket_mode.py
pypaimon/table/file_store_table.py
pypaimon/table/instant.py
pypaimon/table/rollback_helper.py
pypaimon/table/special_fields.py
pypaimon/table/table.py
pypaimon/table/format/__init__.py
pypaimon/table/format/format_batch_write_builder.py
pypaimon/table/format/format_commit_message.py
pypaimon/table/format/format_data_split.py
pypaimon/table/format/format_read_builder.py
pypaimon/table/format/format_table.py
pypaimon/table/format/format_table_commit.py
pypaimon/table/format/format_table_read.py
pypaimon/table/format/format_table_scan.py
pypaimon/table/format/format_table_write.py
pypaimon/table/iceberg/__init__.py
pypaimon/table/iceberg/iceberg_table.py
pypaimon/table/object/__init__.py
pypaimon/table/object/object_read_builder.py
pypaimon/table/object/object_split.py
pypaimon/table/object/object_table.py
pypaimon/table/object/object_table_read.py
pypaimon/table/object/object_table_scan.py
pypaimon/table/row/__init__.py
pypaimon/table/row/binary_row.py
pypaimon/table/row/blob.py
pypaimon/table/row/generic_row.py
pypaimon/table/row/internal_row.py
pypaimon/table/row/key_value.py
pypaimon/table/row/offset_row.py
pypaimon/table/row/projected_row.py
pypaimon/table/row/row_kind.py
pypaimon/table/source/__init__.py
pypaimon/table/source/deletion_file.py
pypaimon/tag/__init__.py
pypaimon/tag/tag.py
pypaimon/tag/tag_manager.py
pypaimon/tests/__init__.py
pypaimon/tests/binary_row_test.py
pypaimon/tests/blob_table_test.py
pypaimon/tests/blob_test.py
pypaimon/tests/branch_manager_test.py
pypaimon/tests/changelog_follow_up_scanner_test.py
pypaimon/tests/changelog_manager_test.py
pypaimon/tests/cli_db_test.py
pypaimon/tests/cli_table_test.py
pypaimon/tests/consumer_manager_test.py
pypaimon/tests/consumer_test.py
pypaimon/tests/data_evolution_test.py
pypaimon/tests/data_types_test.py
pypaimon/tests/delta_varint_compressor_test.py
pypaimon/tests/external_paths_test.py
pypaimon/tests/file_io_test.py
pypaimon/tests/file_store_commit_test.py
pypaimon/tests/filesystem_catalog_test.py
pypaimon/tests/follow_up_scanner_test.py
pypaimon/tests/identifier_test.py
pypaimon/tests/jindo_file_system_test.py
pypaimon/tests/lance_utils_test.py
pypaimon/tests/oss_file_io_test.py
pypaimon/tests/predicates_test.py
pypaimon/tests/pvfs_test.py
pypaimon/tests/range_test.py
pypaimon/tests/ray_data_test.py
pypaimon/tests/ray_sink_test.py
pypaimon/tests/reader_append_only_test.py
pypaimon/tests/reader_base_test.py
pypaimon/tests/reader_predicate_test.py
pypaimon/tests/reader_primary_key_test.py
pypaimon/tests/reader_split_generator_test.py
pypaimon/tests/schema_evolution_read_test.py
pypaimon/tests/schema_manager_test.py
pypaimon/tests/serializable_test.py
pypaimon/tests/shard_table_updator_test.py
pypaimon/tests/snapshot_manager_test.py
pypaimon/tests/sst_file_iterator_test.py
pypaimon/tests/stream_read_builder_test.py
pypaimon/tests/streaming_table_scan_test.py
pypaimon/tests/table_update_test.py
pypaimon/tests/table_upsert_by_key_test.py
pypaimon/tests/torch_read_test.py
pypaimon/tests/uri_reader_factory_test.py
pypaimon/tests/where_parser_test.py
pypaimon/tests/branch/__init__.py
pypaimon/tests/branch/catalog_branch_manager_test.py
pypaimon/tests/branch/file_store_table_branch_manager_test.py
pypaimon/tests/e2e/__init__.py
pypaimon/tests/e2e/java_py_read_write_test.py
pypaimon/tests/manifest/__init__.py
pypaimon/tests/manifest/manifest_entry_identifier_test.py
pypaimon/tests/manifest/manifest_manager_test.py
pypaimon/tests/manifest/manifest_schema_test.py
pypaimon/tests/manifest/simple_stats_evolutions_test.py
pypaimon/tests/py36/__init__.py
pypaimon/tests/py36/ao_predicate_test.py
pypaimon/tests/py36/ao_simple_test.py
pypaimon/tests/py36/data_evolution_test.py
pypaimon/tests/py36/pyarrow_compat.py
pypaimon/tests/py36/reader_predicate_test.py
pypaimon/tests/py36/rest_ao_read_write_test.py
pypaimon/tests/rest/__init__.py
pypaimon/tests/rest/api_test.py
pypaimon/tests/rest/client_test.py
pypaimon/tests/rest/dlf_signer_test.py
pypaimon/tests/rest/rest_base_test.py
pypaimon/tests/rest/rest_catalog_commit_snapshot_test.py
pypaimon/tests/rest/rest_catalog_test.py
pypaimon/tests/rest/rest_format_table_test.py
pypaimon/tests/rest/rest_iceberg_table_test.py
pypaimon/tests/rest/rest_object_table_test.py
pypaimon/tests/rest/rest_permission_test.py
pypaimon/tests/rest/rest_read_write_test.py
pypaimon/tests/rest/rest_server.py
pypaimon/tests/rest/rest_simple_test.py
pypaimon/tests/rest/rest_token_file_io_test.py
pypaimon/tests/rest/test_exponential_retry_strategy.py
pypaimon/tests/rest/test_fuse_local_path.py
pypaimon/tests/scanner/incremental_diff_scanner_test.py
pypaimon/tests/table/file_store_table_test.py
pypaimon/tests/table/simple_table_test.py
pypaimon/tests/write/simple_hash_bucket_assigner_test.py
pypaimon/tests/write/table_write_test.py
pypaimon/utils/__init__.py
pypaimon/utils/file_store_path_factory.py
pypaimon/utils/range.py
pypaimon/utils/range_helper.py
pypaimon/utils/roaring_bitmap.py
pypaimon/write/__init__.py
pypaimon/write/blob_format_writer.py
pypaimon/write/commit_message.py
pypaimon/write/file_store_commit.py
pypaimon/write/file_store_write.py
pypaimon/write/ray_datasink.py
pypaimon/write/row_key_extractor.py
pypaimon/write/table_commit.py
pypaimon/write/table_update.py
pypaimon/write/table_update_by_row_id.py
pypaimon/write/table_upsert_by_key.py
pypaimon/write/table_write.py
pypaimon/write/write_builder.py
pypaimon/write/commit/__init__.py
pypaimon/write/commit/commit_rollback.py
pypaimon/write/commit/commit_scanner.py
pypaimon/write/commit/conflict_detection.py
pypaimon/write/writer/__init__.py
pypaimon/write/writer/append_only_data_writer.py
pypaimon/write/writer/blob_file_writer.py
pypaimon/write/writer/blob_writer.py
pypaimon/write/writer/data_blob_writer.py
pypaimon/write/writer/data_writer.py
pypaimon/write/writer/key_value_data_writer.py