From d0b8bb68561635462f48535c95aad14decac7838 Mon Sep 17 00:00:00 2001 From: fastio Date: Mon, 2 Nov 2026 14:26:28 +0800 Subject: [PATCH] feat(scan): batch read primary-key tables with dynamic buckets --- src/paimon/core/table/table.cpp | 9 ++-- test/inte/scan_and_read_inte_test.cpp | 41 ++++++++++++++++++ test/inte/scan_inte_test.cpp | 2 +- .../pk_dynamic_bucket_dv/README | 21 +++++++++ ...29c4-1fe8-43de-9fe1-13069c7aab48-0.parquet | Bin 0 -> 1109 bytes ...8124-1069-4008-856b-260c74186da9-0.parquet | Bin 0 -> 1108 bytes ...a62b-331e-4c14-8203-a21180e669b3-0.parquet | Bin 0 -> 1108 bytes ...87b9-5534-488d-9b25-72120e6c4eb8-0.parquet | Bin 0 -> 1109 bytes ...6777-2282-4918-94c8-cf34e3ece214-0.parquet | Bin 0 -> 1108 bytes ...67ff-6bb8-4683-b105-7f2455bb8e6e-0.parquet | Bin 0 -> 1109 bytes ...1b16-1a7c-4130-ae38-420d72918dea-0.parquet | Bin 0 -> 1108 bytes ...7b16-1260-426f-b26b-34e3aef797db-0.parquet | Bin 0 -> 1108 bytes ...ddb3-a69c-4c52-b328-66f34f95c002-0.parquet | Bin 0 -> 1108 bytes ...085a-f6e6-4db1-96b1-218cae9c74c5-0.parquet | Bin 0 -> 1109 bytes ...0dfb-303a-4cb6-8da5-de99a724fdf8-0.parquet | Bin 0 -> 1109 bytes ...dex-226a01b7-1ea1-410b-a0f4-c3d72dac3dfb-0 | 1 + ...dex-48eb8ead-486d-4255-9698-f2fc4b10e3cb-0 | 1 + ...dex-6edcb848-8159-4ae7-826d-8995c1a6f454-0 | 1 + ...dex-ed55898c-8f16-432f-8fa3-95727d920a0a-0 | 1 + ...dex-f787a693-854f-4b72-99e0-40217aaca953-0 | 1 + ...est-243d52b5-0cfc-4039-bf11-7436f05ebd99-0 | Bin 0 -> 1029 bytes ...est-2b7a0c3c-2d76-4af8-8733-095d16c3edca-0 | Bin 0 -> 2150 bytes ...est-2b7a0c3c-2d76-4af8-8733-095d16c3edca-1 | Bin 0 -> 2241 bytes ...est-4cdd7c93-4b8d-45b5-92c0-9e5bd21bc1eb-0 | Bin 0 -> 2152 bytes ...est-4cdd7c93-4b8d-45b5-92c0-9e5bd21bc1eb-1 | Bin 0 -> 2325 bytes ...est-bcf33eac-adb4-4446-8da1-b434b89c2705-0 | Bin 0 -> 2292 bytes ...est-bcf33eac-adb4-4446-8da1-b434b89c2705-1 | Bin 0 -> 2336 bytes ...ist-0014d5c7-8244-459c-ba6c-3e66042c6b22-0 | Bin 0 -> 884 bytes ...ist-0014d5c7-8244-459c-ba6c-3e66042c6b22-1 | Bin 0 -> 990 bytes ...ist-0014d5c7-8244-459c-ba6c-3e66042c6b22-2 | Bin 0 -> 990 bytes ...ist-0014d5c7-8244-459c-ba6c-3e66042c6b22-3 | Bin 0 -> 990 bytes ...ist-19ad07c9-fcfc-4be6-b685-d6918922e81b-0 | Bin 0 -> 1001 bytes ...ist-19ad07c9-fcfc-4be6-b685-d6918922e81b-1 | Bin 0 -> 991 bytes ...ist-19ad07c9-fcfc-4be6-b685-d6918922e81b-2 | Bin 0 -> 1043 bytes ...ist-19ad07c9-fcfc-4be6-b685-d6918922e81b-3 | Bin 0 -> 991 bytes ...ist-51b6b5dd-86de-4a97-9a90-86dc8382f85e-0 | Bin 0 -> 1051 bytes ...ist-51b6b5dd-86de-4a97-9a90-86dc8382f85e-1 | Bin 0 -> 991 bytes ...ist-51b6b5dd-86de-4a97-9a90-86dc8382f85e-2 | Bin 0 -> 1091 bytes ...ist-51b6b5dd-86de-4a97-9a90-86dc8382f85e-3 | Bin 0 -> 991 bytes .../pk_dynamic_bucket_dv/schema/schema-0 | 24 ++++++++++ .../pk_dynamic_bucket_dv/snapshot/EARLIEST | 1 + .../pk_dynamic_bucket_dv/snapshot/LATEST | 1 + .../pk_dynamic_bucket_dv/snapshot/snapshot-1 | 20 +++++++++ .../pk_dynamic_bucket_dv/snapshot/snapshot-2 | 20 +++++++++ .../pk_dynamic_bucket_dv/snapshot/snapshot-3 | 20 +++++++++ .../pk_dynamic_bucket_dv/snapshot/snapshot-4 | 20 +++++++++ .../pk_dynamic_bucket_dv/snapshot/snapshot-5 | 20 +++++++++ .../pk_dynamic_bucket_dv/snapshot/snapshot-6 | 20 +++++++++ 48 files changed, 220 insertions(+), 4 deletions(-) create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/README create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-101/data-03e129c4-1fe8-43de-9fe1-13069c7aab48-0.parquet create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-101/data-18c28124-1069-4008-856b-260c74186da9-0.parquet create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-101/data-78d3a62b-331e-4c14-8203-a21180e669b3-0.parquet create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-179/data-090287b9-5534-488d-9b25-72120e6c4eb8-0.parquet create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-179/data-8f746777-2282-4918-94c8-cf34e3ece214-0.parquet create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-191/data-a6fa67ff-6bb8-4683-b105-7f2455bb8e6e-0.parquet create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-191/data-e9bc1b16-1a7c-4130-ae38-420d72918dea-0.parquet create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-193/data-7e957b16-1260-426f-b26b-34e3aef797db-0.parquet create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-193/data-8fc5ddb3-a69c-4c52-b328-66f34f95c002-0.parquet create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-193/data-f3ec085a-f6e6-4db1-96b1-218cae9c74c5-0.parquet create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-20/data-e2c90dfb-303a-4cb6-8da5-de99a724fdf8-0.parquet create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-226a01b7-1ea1-410b-a0f4-c3d72dac3dfb-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-48eb8ead-486d-4255-9698-f2fc4b10e3cb-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-6edcb848-8159-4ae7-826d-8995c1a6f454-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-ed55898c-8f16-432f-8fa3-95727d920a0a-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-f787a693-854f-4b72-99e0-40217aaca953-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/index-manifest-243d52b5-0cfc-4039-bf11-7436f05ebd99-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-2b7a0c3c-2d76-4af8-8733-095d16c3edca-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-2b7a0c3c-2d76-4af8-8733-095d16c3edca-1 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-4cdd7c93-4b8d-45b5-92c0-9e5bd21bc1eb-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-4cdd7c93-4b8d-45b5-92c0-9e5bd21bc1eb-1 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-bcf33eac-adb4-4446-8da1-b434b89c2705-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-bcf33eac-adb4-4446-8da1-b434b89c2705-1 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-1 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-2 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-3 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-1 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-2 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-3 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-1 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-2 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-3 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/schema/schema-0 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/EARLIEST create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/LATEST create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-1 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-2 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-3 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-4 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-5 create mode 100644 test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-6 diff --git a/src/paimon/core/table/table.cpp b/src/paimon/core/table/table.cpp index e8341421d..4c638305b 100644 --- a/src/paimon/core/table/table.cpp +++ b/src/paimon/core/table/table.cpp @@ -871,9 +871,12 @@ Result> NewDataTableScan( ValidateRealtimeScan(*table_schema, core_options, *context, read_optimized)); // validate options if (core_options.GetBucket() == -1) { - if (!table_schema->PrimaryKeys().empty()) { - return Status::NotImplemented(fmt::format( - "do not support pk table bucket={} in scan process", core_options.GetBucket())); + // Batch planning of dynamic bucket primary key tables only depends on the buckets + // recorded in the manifest, and deletion vectors are looked up per (partition, bucket). + if (!table_schema->PrimaryKeys().empty() && context->IsStreamingMode()) { + return Status::NotImplemented( + fmt::format("do not support pk table bucket={} in streaming scan process", + core_options.GetBucket())); } } else if (core_options.GetBucket() < 1 && !SchemaValidation::IsPostponeBucketTable(*table_schema, core_options.GetBucket())) { diff --git a/test/inte/scan_and_read_inte_test.cpp b/test/inte/scan_and_read_inte_test.cpp index 17807e254..d37cf938b 100644 --- a/test/inte/scan_and_read_inte_test.cpp +++ b/test/inte/scan_and_read_inte_test.cpp @@ -3124,6 +3124,47 @@ TEST_P(ScanAndReadInteTest, TestScanAndReadWithDisableIndex) { ASSERT_TRUE(expected->Equals(read_result)) << read_result->ToString(); } +TEST(ScanAndReadDynamicBucketInteTest, TestBatchReadPkDynamicBucketWithDeletionVectors) { + // Written by Java Paimon. Keys spread over several dynamic buckets, each with its own + // deletion vector index, so deletion vectors must be looked up per (partition, bucket). + const std::string table_path = + GetDataDir() + "/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/"; + const std::shared_ptr result_type = + arrow::struct_({arrow::field("_VALUE_KIND", arrow::int8()), + arrow::field("id", arrow::int32()), arrow::field("v", arrow::utf8())}); + const std::vector> cases = { + {"2", R"([[0, 1, "a"], [0, 2, "b"], [0, 3, "x"], [0, 4, "y"], [0, 5, "z"]])"}, + {"4", R"([[0, 1, "c"], [0, 2, "b"], [0, 3, "x"], [0, 4, "w"], [0, 5, "z"]])"}, + {"6", R"([[0, 1, "c"], [0, 3, "x"], [0, 4, "w"]])"}, + }; + for (const auto& [snapshot_id, expected_json] : cases) { + SCOPED_TRACE("snapshot " + snapshot_id); + ScanContextBuilder scan_context_builder(table_path); + scan_context_builder.AddOption(Options::SCAN_SNAPSHOT_ID, snapshot_id); + ASSERT_OK_AND_ASSIGN(std::unique_ptr scan_context, + scan_context_builder.Finish()); + ASSERT_OK_AND_ASSIGN(std::unique_ptr table_scan, + TableScan::Create(std::move(scan_context))); + ASSERT_OK_AND_ASSIGN(std::shared_ptr plan, table_scan->CreatePlan()); + ASSERT_GT(plan->Splits().size(), 1); + + ReadContextBuilder read_context_builder(table_path); + ASSERT_OK_AND_ASSIGN(std::unique_ptr read_context, + read_context_builder.Finish()); + ASSERT_OK_AND_ASSIGN(std::unique_ptr table_read, + TableRead::Create(std::move(read_context))); + ASSERT_OK_AND_ASSIGN(std::unique_ptr batch_reader, + table_read->CreateReader(plan->Splits())); + ASSERT_OK_AND_ASSIGN(std::shared_ptr actual, + ReadResultCollector::CollectResult(std::move(batch_reader))); + const std::shared_ptr sort_schema = arrow::schema(result_type->fields()); + ASSERT_OK_AND_ASSIGN(actual, ReadResultCollector::SortArray(actual, sort_schema)); + const std::shared_ptr expected = std::make_shared( + arrow::ipc::internal::json::ArrayFromJSON(result_type, expected_json).ValueOrDie()); + ASSERT_TRUE(expected->Equals(actual)) << actual->ToString(); + } +} + TEST(ScanAndReadFileIndexInteTest, TestPkDvEmbeddedBitmapFiltersScanAndRead) { std::unique_ptr dir = UniqueTestDirectory::Create("local"); ASSERT_NE(nullptr, dir); diff --git a/test/inte/scan_inte_test.cpp b/test/inte/scan_inte_test.cpp index 3f949484d..216346d1b 100644 --- a/test/inte/scan_inte_test.cpp +++ b/test/inte/scan_inte_test.cpp @@ -1730,7 +1730,7 @@ TEST_P(ScanInteTest, TestScanPKWithInvalidOptions) { context_builder.AddOption(Options::BUCKET, "-1").WithStreamingMode(true); ASSERT_OK_AND_ASSIGN(auto scan_context, FinishScanContext(context_builder)); ASSERT_NOK_WITH_MSG(TableScan::Create(std::move(scan_context)), - "do not support pk table bucket=-1 in scan process"); + "do not support pk table bucket=-1 in streaming scan process"); } TEST_P(ScanInteTest, TestReadWithNoSnapshot) { diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/README b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/README new file mode 100644 index 000000000..283720e93 --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/README @@ -0,0 +1,21 @@ +Written by Spark 3.5.3 with Paimon 1.3.2. + +id:int not null v:string +primary key: id +bucket: -1 (dynamic bucket) +dynamic-bucket.target-row-num = 2 +deletion-vectors.enabled = true +file.format = parquet + +CREATE TABLE dv (id INT, v STRING) +TBLPROPERTIES ('primary-key' = 'id', 'bucket' = '-1', 'deletion-vectors.enabled' = 'true', + 'file.format' = 'parquet', 'dynamic-bucket.target-row-num' = '2'); + +INSERT INTO dv VALUES (1, 'a'), (2, 'b'), (3, 'x'), (4, 'y'), (5, 'z'); +-- snapshot 2: (1, a) (2, b) (3, x) (4, y) (5, z) +INSERT INTO dv VALUES (1, 'c'), (4, 'w'); +-- snapshot 4: (1, c) (2, b) (3, x) (4, w) (5, z) +DELETE FROM dv WHERE id IN (2, 5); +-- snapshot 6: (1, c) (3, x) (4, w) + +Keys are spread over several buckets, and each bucket keeps its own deletion vector index. diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-101/data-03e129c4-1fe8-43de-9fe1-13069c7aab48-0.parquet b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-101/data-03e129c4-1fe8-43de-9fe1-13069c7aab48-0.parquet new file mode 100644 index 0000000000000000000000000000000000000000..717830dd48c5af380816f2831b24958b82744b3d GIT binary patch literal 1109 zcma)+&ubGw6vy9AHpyZmw%8dmu*hDrqz7x#X46E1SnWb>HPlLiLSRYK1OrW5Qya+5 zvq#T8i1eTk5D$9vtmhX4eDAq9ER!-mfg9#=)qUPlRMz!|ng8gZ|Dc-$XOI0=9t zh;GvOKfKc8ai!<)F)=@`GmRFRAnL44%igH3_>03}I3Tow4kBHIY_DG2tG3#^JI;Rn zaid+O7jQKJ@u;(IKXO`IrN5)mC<;`?wQ1*peZOQEZ`)3>bnlkES^AB}OLD`MQ(nGX zvYqui#g)VrYbY#w|FSmY7KpnE!m!p@g2a_>0xY8IXhPj|UNHfM=LroJISou>jIb;# znp#21En5ajSA03cdhyy|0#KNfCjjg?OlR3qh+YRlRV8&Ibr*kwmCbS?IHh2OVf?cT zR?iCeLxlStqHAtAuZVFm{6hK)R)QsiY(*u(>@4)JFlFqu>Q&;QQAVFQ6hr|zuQtyk zNc?$9jB!hgpyW!|C9bfFIUohRT=-&kZao&%rE<;u!cw!E&RF?W geQ~i?x0;!yY$jzjYuVf!ui*U{f8i}g-oPKqKkqo6TmS$7 literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-101/data-18c28124-1069-4008-856b-260c74186da9-0.parquet b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-101/data-18c28124-1069-4008-856b-260c74186da9-0.parquet new file mode 100644 index 0000000000000000000000000000000000000000..626fd494015d401ef6629cdd88b7534e4d31b73b GIT binary patch literal 1108 zcma)+O=uHQ5XWaO715X*3 z<21hg@#&-H(IOb6cNc&WFr-j|(4|I9FcDK_%6^ATa1fkY<{35VDjyLGh9gcAAPKS? zHU1B;bVW?*2764(Pv~630+&RcmvGG=9Vo%#@nCq!uuKjzU4m>Zp4+Z8TU(pXPVIiZ zRlzf~8i&}JvuxjUn(M{CyAW+^{7rNM~81ZOu` zJt^Eb8SZNcm)vlE5yN5xg&ZhU36%_9D=QhyPD1|-Bj?XmzY-r!G6uwBNtBS&YV$Zk z#P5A#R9ISsBv(2vae!nxs#9 zX}i*Xuv>q4sns?*_4ZD4Ytu+gr>yB2BT?OLZmb(wD_5`7QW>k7%r7>=DX0lVFO!s5>g;x}Lh5jf104VmI*Z=?k literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-101/data-78d3a62b-331e-4c14-8203-a21180e669b3-0.parquet b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-101/data-78d3a62b-331e-4c14-8203-a21180e669b3-0.parquet new file mode 100644 index 0000000000000000000000000000000000000000..626fd494015d401ef6629cdd88b7534e4d31b73b GIT binary patch literal 1108 zcma)+O=uHQ5XWaO715X*3 z<21hg@#&-H(IOb6cNc&WFr-j|(4|I9FcDK_%6^ATa1fkY<{35VDjyLGh9gcAAPKS? zHU1B;bVW?*2764(Pv~630+&RcmvGG=9Vo%#@nCq!uuKjzU4m>Zp4+Z8TU(pXPVIiZ zRlzf~8i&}JvuxjUn(M{CyAW+^{7rNM~81ZOu` zJt^Eb8SZNcm)vlE5yN5xg&ZhU36%_9D=QhyPD1|-Bj?XmzY-r!G6uwBNtBS&YV$Zk z#P5A#R9ISsBv(2vae!nxs#9 zX}i*Xuv>q4sns?*_4ZD4Ytu+gr>yB2BT?OLZmb(wD_5`7QW>k7%r7>=DX0lVFO!s5>g;x}Lh5jf104VmI*Z=?k literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-179/data-090287b9-5534-488d-9b25-72120e6c4eb8-0.parquet b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-179/data-090287b9-5534-488d-9b25-72120e6c4eb8-0.parquet new file mode 100644 index 0000000000000000000000000000000000000000..877bdccb1398c5997e15875f0e55b0ffdce2bb7d GIT binary patch literal 1109 zcma)6PiqrF6n{I}B&$Yju`^^~k-cO|55}a;rilcx+J)L`sFehTz>-Z93^Z*`Z9jyc zp$88=Civyn|JgJJD{fQFJfHNG4bmCe0@MN$Y1E~Un3}PC0 zo=2~^JgKOa_A{rmR{b{|4&y*ov`siq?8jBRa^H3;)kpX2)#@K~UXur|IJNnQRohv9 zP+3Ubum-}T_pfV{UV(U;AQ{%0NRgznn*xjII=WCdo!3pkYvd^n6*&z|6O6C|tC(6@ z$}L9*X-|B)!+No8Faan}%Nqc86s1#aKSFPVU{xjSSn3}A9ab}IzKWPmMALj03?adgY?pyow>? zk5k43x3m~auIze@3#@J)k}@_IzL=dikL2YE%tgNedmW=X+l$gHuzkXasjTP#6H;h~+XJuxLw7b(;Uo(nUsnuxa3YMEKwo5Z}?M5zdm9ov* eS+{Am^K*rK)@r+j;xw;ge~i9xfRR`5hw>kygP$n? literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-179/data-8f746777-2282-4918-94c8-cf34e3ece214-0.parquet b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-179/data-8f746777-2282-4918-94c8-cf34e3ece214-0.parquet new file mode 100644 index 0000000000000000000000000000000000000000..4b6156d5a64e11c6eef47b4488109054ef50d991 GIT binary patch literal 1108 zcma)6&ubG=5T1S6q^m}3vGd4-MfQ>GdlNFjL2w$G@6=?dd_*i*js&TaBO%CX z)cHSn#T7Bd4bGS(pU}C6MJ^F_UdGklYF`PA$Aje|!wLmRx&*SmaDJ=WY;A5h+qDPv zRu#{ZH4d>cXUV?rG}lUhy4~&=ph~uJ=dOLHWEXGPPO)_Ry1i2RMa~QUfpboI?pDcm zmTng3d|oK~AB z5kmaZM~n(fi;(0>$3vXw74wi4sJZARcHTV1%M)10egpn2f;!&~V+!~lBX&T`{7Rg(dAa#=+xWW&CLxXolINFX(Qq8G}qURoRzOvYw4`zrgDw^^lYP=&RF?W gZDz);S&htWHj}a%ZZR literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-191/data-a6fa67ff-6bb8-4683-b105-7f2455bb8e6e-0.parquet b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-191/data-a6fa67ff-6bb8-4683-b105-7f2455bb8e6e-0.parquet new file mode 100644 index 0000000000000000000000000000000000000000..2528c8bcdabdb8f2bc1681d3510b230e1db2d3ba GIT binary patch literal 1109 zcma)6&ubGw6n;C|B&$Yku`^^~k-cO|55}a;rilcx+J)L`sFehTz>=g12AZ~}Hi!HP zy?FB0gF+7q0rBAf&_fXfPaZ_XdoP}%w!Ycf?gmn%%Q8RSd-J{bee-r#=2tTms74L? z=JU(lD>^0aRs%?Wy!jUv4S+BJC;(`mph^1m%i)LUSlAtm@g5l}5RZ;Ny;H|R4H*}N zog*=$DSG_-=c@}6EkgbJo&XR83@L~QeH{2C;c->e>`jz#2AttYq!Z7|hsXWpSdc10 z5J61i&i}zHeI8f({uvYN<2uu5i3voVRcOUq4HVxv43-CkRxv=7iy-TZm$z!|&gO=* z-FVjQ)aXUDCLkVlmhGobd#!wYa&i&{s-kVed2Bx_+ogN9Qz}2aYp<67p!2FcaLK96 zKPcPI^8M06;<_~y9({04n{)}{X@X$LHI^W8rI!GU=sLPkH=S2aK;d~pLq$##(-eb{ zb|Z-R;}kK*EiHnQD?Jx+fmO`|QpD!M7prsUk-A)gx#%}wuOn1vdtsUewoe!_HMSR; z!f$$MtJZzK(|mEG(=~d{?sj`~!^osER%*sb)_2++fw%)K>*|}UcZMEvT{4}p(e~iBH9y71t59J>mzn=U6 literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-191/data-e9bc1b16-1a7c-4130-ae38-420d72918dea-0.parquet b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-191/data-e9bc1b16-1a7c-4130-ae38-420d72918dea-0.parquet new file mode 100644 index 0000000000000000000000000000000000000000..60264a5d98054b2133859d7e09f5ffbfbf7ce77d GIT binary patch literal 1108 zcma)6&1(};5TAYd=&Dg$>^$;dk-cO|4^5LcnHxm~ z!cLKwV+@ae|9F1JMGK-w?=Ao%G@n8Qp-qDrV=D6?0r7YP^7}-POM084vr*1BOKkkaP)Tec}98sovP! zu(vDstBn$#C2Iu2BlePY&#tfKk2;;s2%w*AqxK!^cHYWex9nX0)-`J-|A(9x-2>x%||YqzobWdb4eX@3Z&DFz^K+xgoTw>1WcxB>p=aZMo8-YjXz}3AVeYl7yT2Ef|n{5`{p44hTGN_55`0zw%j(}7N@VC+6 z|L7HuCloJy$He-$&NOhCNU5_5tOeGQ5;}VW^O!;v0is+a*;u@?U2CBNBttWvqzR>)Bo@_m454m1ubKpf=SdAEJ4+04Mp>RYrdE=2 z%axIoFTOlszc>rXPfFAB1_=8cg(-Fzfty6Is*-i2bf3P&*33$2a7zOV(}Z_7@Sd0M zn@IOH0!x0npow8I!bXl1>_l98wF>i#uh=I-yqL3l%kTPm&>>x6QKk23I zT4!g!v3I@QF}jV;Zfk4P$fmPadd5iA_gfq5M!_mJYF;*P)iZ@=ab~Vr%jT?N#+#k3 ddsZ_ym(OLaW<6h+=2e`J;fK7%%q#eR@(>p=aZMo8-YjXz}3AVeYl7yT2Ef|n{5`{p44hTGN_55`0zw%j(}7N@VC+6 z|L7HuCloJy$He-$&NOhCNU5_5tOeGQ5;}VW^O!;v0is+a*;u@?U2CBNBttWvqzR>)Bo@_m454m1ubKpf=SdAEJ4+04Mp>RYrdE=2 z%axIoFTOlszc>rXPfFAB1_=8cg(-Fzfty6Is*-i2bf3P&*33$2a7zOV(}Z_7@Sd0M zn@IOH0!x0npow8I!bXl1>_l98wF>i#uh=I-yqL3l%kTPm&>>x6QKk23I zT4!g!v3I@QF}jV;Zfk4P$fmPadd5iA_gfq5M!_mJYF;*P)iZ@=ab~Vr%jT?N#+#k3 ddsZ_ym(OLaW<6h+=2e`J;fK7%%q#eR@(0xj)fXBE)2Us zVg|GD{^Qq|F^Lv~puP=4C;~*G4ppv(lK&ZW!vCDUDr(Ah($6l}eM(2b)aM`IY-mlos z>b>$(>Y6nW9=(56oAL{3<*YAo|R3l zB;}SPBWX{3xkJ9#3s?Xt&Bz-d>?8`)>@Wg1i9l5)>R9O>{4G{BtEKRk!WE_o?k=>R zm+rer_bmb|UOJz|s2Bl}zJg4UGLfTT67J4}{uu?vUaLM69~xy05C;NL^vXrGc@aaz zA7_XOZfP-;TYScu literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-20/data-e2c90dfb-303a-4cb6-8da5-de99a724fdf8-0.parquet b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/bucket-20/data-e2c90dfb-303a-4cb6-8da5-de99a724fdf8-0.parquet new file mode 100644 index 0000000000000000000000000000000000000000..d45ce873f9cebe99d0bdda1f4cca33d3e56e57f2 GIT binary patch literal 1109 zcma)6&ubGw6n;CqNfwRRVrR&}B74b_9*jwwO%n-XwF|Y?P%8-vfh9>33^Z*`ZOA|1 z#e-KbJ$NXh5D*XIzfh!jvKJ2`{sX;u3Tk|_lkNsmq{}it-h1=C_kHtr*A~~)6sS&3 zdi?z5Ct^_IZFPXe$LoJ!*#uAlKmkDe6iv`?UynXSCcD)NGG0^50ClFi6Bjc zAcB}Co&SSZdOW7|{4*BT#|@^_A`^%PE7S65)mMDuAXpv}TEPHOE`n?>U)rg*+S^<1 zZv9E4U8NV$8i!cKU3DJ2t&P&(;cyrMs-bPleds(WImJ7UTP)qb?W~u6qw}&naM3L< z-YYro>fPc}{Hi?=9;1InpY{miX@X$LH5w-|r5gvE7zVmfH-lF!K;d~@M@3E(( z%Zip>kaEkBLBbPX?vO9G4Hf`}S$PA%jzV;X9jNpM2vkj?PL%G!-(+R0TnKI{SYaCf z?gHys>3)cG-&MNer5lkL7sDsgSC9!(2002Q!R{>RUm?oaTW!Q-1dTHKhy#HrdgZ*@ zya*%W&r`%GxAibeu5>-bC04NxNdcP+U#!lX$LjI~=Az$#y$(}@?T2Uz*a2b0(%HT` zgWvSZPPOxNukq|!yJL16o!!>F%5K)OxmjMp{uqDZJ!W3RAId+-OrAyn literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-226a01b7-1ea1-410b-a0f4-c3d72dac3dfb-0 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-226a01b7-1ea1-410b-a0f4-c3d72dac3dfb-0 new file mode 100644 index 000000000..fd298348b --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-226a01b7-1ea1-410b-a0f4-c3d72dac3dfb-0 @@ -0,0 +1 @@ +ÒåG \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-48eb8ead-486d-4255-9698-f2fc4b10e3cb-0 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-48eb8ead-486d-4255-9698-f2fc4b10e3cb-0 new file mode 100644 index 000000000..834de8ef9 --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-48eb8ead-486d-4255-9698-f2fc4b10e3cb-0 @@ -0,0 +1 @@ +VGpÊ \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-6edcb848-8159-4ae7-826d-8995c1a6f454-0 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-6edcb848-8159-4ae7-826d-8995c1a6f454-0 new file mode 100644 index 000000000..11dc1c01e --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-6edcb848-8159-4ae7-826d-8995c1a6f454-0 @@ -0,0 +1 @@ +‚Hô \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-ed55898c-8f16-432f-8fa3-95727d920a0a-0 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-ed55898c-8f16-432f-8fa3-95727d920a0a-0 new file mode 100644 index 000000000..599a74a8f --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-ed55898c-8f16-432f-8fa3-95727d920a0a-0 @@ -0,0 +1 @@ +Oä»ð \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-f787a693-854f-4b72-99e0-40217aaca953-0 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-f787a693-854f-4b72-99e0-40217aaca953-0 new file mode 100644 index 000000000..8095133ba --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/index/index-f787a693-854f-4b72-99e0-40217aaca953-0 @@ -0,0 +1 @@ +WYùž \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/index-manifest-243d52b5-0cfc-4039-bf11-7436f05ebd99-0 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/index-manifest-243d52b5-0cfc-4039-bf11-7436f05ebd99-0 new file mode 100644 index 0000000000000000000000000000000000000000..5c22b223d658721903e31e66d61c73f5e78ade2b GIT binary patch literal 1029 zcmeZI%3@>@ODrqO*DFrWNX<=r#a*pbQdy9yWTjM;nw(#hqNJmgmzayeFD^(-1_|aD zrRyaE*%_&N1&Nut`FVO^!_rgpQi~ExQbF3&GE;L>ij}OQt6?U^hq(p?d;0qUC82g@ z=9MVb>L3(&d-}QHmJM(W3h@j z%u7cx#?8~mHQvwBmk3qCo>54ua`Mqk3i1z+clHnULvj;_8W&d|SCGeofkEUP;vW*e;_;w&x=*Kx zZeAzuEdA3uS)f&RtzPGEzv(40$K2gMw21z6JaXd>?}m+czwMm-`;hnkbq{zWe=S)( zb1etklrEztgSFAuO@E&`ygjgHbI=kIMlpjzNj1&#uepBpB9F~G;{pS-QajoVI}XJa zSsKb0wV7}IZOyUY;A<+cyzOhwRf2pxe5@?(N)Cw}JW8Alo)1_KerIUs+{bR=^TGCk Of!0E2W&uWYZvg;5Q)d1E literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-2b7a0c3c-2d76-4af8-8733-095d16c3edca-0 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-2b7a0c3c-2d76-4af8-8733-095d16c3edca-0 new file mode 100644 index 0000000000000000000000000000000000000000..45be5a6fec0fc3c98802022408340b9ed4c71fdf GIT binary patch literal 2150 zcmdT_O=#0#7;be_CW3Cx;Xq+T5XWjo*$?iZ&Dw7+E={{MS?gvES(|o|{FF2u)KQp- zm%4)r+d(fw^r9d`5WH**K~X_=*hw7-qA-7OAh^>+zoc!FwQIYB7jJF9=Y78SeZJ>? z>KnOauW4e(6xo@KjB+A7e`p+0(+LjgMiee0D^bLONUT`$J(*x5+K;jlce3#FDCbPD zyeLafoh;5toWiP{RvzOyA(}+GhsO&{%pf2Gn2&&m`MY>YMKTT((2o(G@~3{3q%dj& z!AM%=k{c*`Xm>xL%9Bt&3dNZmDo`HQi{ZdHt)dOXNUxbq^j^zd_&VZ zDu4}HP=Z{9A$>u{?V}0HY$X^kMlk*0ywNyPs*e{9Rf9kVCP1N-DbJP!U^HH%a1$-G z?gmku1}1Tt2CJh88pm^Tm}J9280%+!YBvc`Em#-|vutX?F9wy~ zmjl`-&PP~*%H^fXi(FD=#l$g@7X%)rQHifC3FiSgpa4_4%!SMH<}9|Rg#tkNJs#lE z2WDVmf{-DN!IE42N}c2~$48THGj)t|P2oz#mfe6`h?}w(7!1wI$zO>bz9%3F7}I`~ z>MNZsAE1>OdNDFU=_*@%Rp_m{#6c2+kMxfQgQ*hEH0uA45jo058ZJY-NKsaa+6Lt8 zY{%=V&r+@X{;TJX)ta?!N1q)3ZR?w=wIOvaM`k*{tYo97&pf=_Y&+a}`|%s`rgv<; zE3xcqBDNQ666cOJA(O`eFoUHXYGrf;2f%r@+| zxtd&ip6>SBe_Xj{AF^d8Vl~qXZR6i&>QCmO{j6~kA?g-fwoj1>NAWa&0qAze AmjD0& literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-2b7a0c3c-2d76-4af8-8733-095d16c3edca-1 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-2b7a0c3c-2d76-4af8-8733-095d16c3edca-1 new file mode 100644 index 0000000000000000000000000000000000000000..9a589db620154302e4c05260d4b699fe541c816b GIT binary patch literal 2241 zcmeZI%3@>@ODrqO*DFrWNX<>$CtIylQdy9yWTjM;nw(#hqNJmgmzayeFD^(-1_|aD zrRyaE*%_&N1&Nut`FVO^!_rgpQi~ExQbF3&GE;L>ij}OQt6?U^hq(p?d;0qUC82g@ z=9MVb>L3(&d-}QHmJM(W3h@j-~-QA$ZoODxSP zQL+N*tc|TjPK;nj!2JU;5^gm1Tmnf6@ep6awGRED0L5IeYhb9WpEEEuhx$6X1|iZI zW-0_GG2&GRJA1hLI>vhnLR!|}ip(=`GfG;mWO86TfZAZ3n!Xpl3a z)PZXUg)lzNNO=R83w;p54l@BBX1IbMpXtE(bPe(Y7SjQaAs(21gBGCpOmOoI3Jw8> zGE%yNxs7lThX;8ABZ*2L1C}bWwIbm9F*!daHCd<%m|XHw5{pt8Zagxue7KR zg7ze(J2JZ*X>yiRkX%`Cy*|xu{}1~KjD2iA77iI~EN-_Q>$qmw?lxJQ+*PvK$jftP z^xihf+}^e$u3j+;l8ovK4UFu@ODrqO*DFrWNX<>$CtIylQdy9yWTjM;nw(#hqNJmgmzayeFD^(-1_|aD zrRyaE*%_&N1&Nut`FVO^!_rgpQi~ExQbF3&GE;L>ij}OQt6?U^hq(p?d;0qUC82g@ z=9MVb>L3(&d-}QHmJM(W3h@j-~-QA$ZoODxSP zQL+N*tc|TjPK;nj!2JU;5^gm1Tmnf6@ep6awGRED0L5IeYhb9WpEEEuhx$6X1|iZI zW-0_GG2&GRJA1hLI>vhnLR!|}ip(=`GfG;mWO86TfZAZ3n!Xpl3a z)PZXUg)lzNNO=R83w;p54l@BBX1IbMpXtE(bPe(Y7SjQaAs(21gBGCpOmOoI3Jw8> zGE%yNxs7lThX;8ABZ*2L1C}bWwIbm9F*!daHCd<%m|XHw5{pt8yc{;1jTHSg}TV z!<`)@9%qT z`k(jz&e&M}^7m*w+}YjoNRca3@$!^wM~+YYcqp!5c3e)d{?@e##u^*n7Ry~;;PALP zTa>{;%z-~?92lM?H|U`I F2LKN;(iH#z literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-4cdd7c93-4b8d-45b5-92c0-9e5bd21bc1eb-1 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-4cdd7c93-4b8d-45b5-92c0-9e5bd21bc1eb-1 new file mode 100644 index 0000000000000000000000000000000000000000..940814ab280e5a83d57bcc2e09ae91965907bb8c GIT binary patch literal 2325 zcmeZI%3@>@ODrqO*DFrWNX<>$CtIylQdy9yWTjM;nw(#hqNJmgmzayeFD^(-1_|aD zrRyaE*%_&N1&Nut`FVO^!_rgpQi~ExQbF3&GE;L>ij}OQt6?U^hq(p?d;0qUC82g@ z=9MVb>L3(&d-}QHmJM(W3h@j-~-QA$ZoODxSP zQL+N*tc|TjPK;nj!2JU;5^gm1Tmnf6@ep6awGRED0L5IeYhb9WpEEEuhx$6X1|iZI zW-0_GG2&GRJA1hLI>vhnLR!|}ip(=`GfG;mWO86TfZAZ3n!Xpl3a z)PZXUg)lzNNO=R83w;p54l@BBX1IbMpXtE(bPe(Y7SjQaAs(21gBGCpOmOoI3Jw8> zGE%yNxs7lThX;8ABZ*2L1C}bWwIbm9F*!daHCd<%m|XHw5{pt8mQCo1Kf=QEA>e$z zZ)sJIEzcEJjjj5B89aEo8Oo;EYcDW;x%hXJ>DdpDJ-g&{;tS87h*Po6cJ`Y2qrM^K zR;IUR>!$9|?fX(L`!Sj@m@*hM><|)^H8d7`Wz|4*6mU!#shdH=H%l9%ADs;- z?BBFb$K80#h4OEEC7P#LhF@FCeC?;eMwzo0oZ{2>cwX~+7b-AsMR?xK)MFl#^%(#B e=546q*v4Ar~W+NeK!Q`UN+m2R;D4q8*F? literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-bcf33eac-adb4-4446-8da1-b434b89c2705-0 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-bcf33eac-adb4-4446-8da1-b434b89c2705-0 new file mode 100644 index 0000000000000000000000000000000000000000..d2ff72e11e210989c8593ceead7f526a32fbc7cc GIT binary patch literal 2292 zcmeZI%3@>@ODrqO*DFrWNX<>$CtIylQdy9yWTjM;nw(#hqNJmgmzayeFD^(-1_|aD zrRyaE*%_&N1&Nut`FVO^!_rgpQi~ExQbF3&GE;L>ij}OQt6?U^hq(p?d;0qUC82g@ z=9MVb>L3(&d-}QHmJM(W3h@j-~-QA$ZoODxSP zQL+N*tc|TjPK;nj!2JU;5^gm1Tmnf6@ep6awGRED0L5IeYhb9WpEEEuhx$6X1|iZI zW-0_GG2&GRJA1hLI>vhnLR!|}ip(=`GfG;mWO86TfZAZ3n!Xpl3a z)PZXUg)lzNNO=R83w;p54l@BBX1IbMpXtE(bPe(Y7SjQaAs(21gBGCpOmOoI3Jw8> zGE%yNxs7lThX;8ABZ*2L1C}bWwIbm9F*!daHCd<%m|XHw5{pt8K730H|8;Zvx_bpe zt4^KR%fvN_Rb#9EUj`3WE{0=)mYNeZbGNVB9LoE~-l^`$j-S_dr(ON^_x!VIhyQO- z+P!=Cb)5&&zjP+fP2tjG&}GnJ*nR85qE&sY4HbVJ8y$r?Wa@&?O^tE>F)8x&@w1N~ zg}HC^uT1bc|2M<3+nM08P}hji+Evo*maDIe*?&J)yzAQL(zcfM@87Na-}Tnt>7=1IU*x{+6`IE+c2&PT zus0*3frXDhcGr|3uI|&WKV;>-diFTF>4|U8pFDf7aQxXeCO4H%70*d3_y6rQ-gc?v z43n9{gse5_UVf~Vqcd2{hsI6T0LdwCYiGroZ?%* uC$R+r)lS!K0;)~Y-cwr?IKOHFC;w4~-$v@CGg8`IINAR3^m?@ODrqO*DFrWNX<>$CtIylQdy9yWTjM;nw(#hqNJmgmzayeFD^(-1_|aD zrRyaE*%_&N1&Nut`FVO^!_rgpQi~ExQbF3&GE;L>ij}OQt6?U^hq(p?d;0qUC82g@ z=9MVb>L3(&d-}QHmJM(W3h@j-~-QA$ZoODxSP zQL+N*tc|TjPK;nj!2JU;5^gm1Tmnf6@ep6awGRED0L5IeYhb9WpEEEuhx$6X1|iZI zW-0_GG2&GRJA1hLI>vhnLR!|}ip(=`GfG;mWO86TfZAZ3n!Xpl3a z)PZXUg)lzNNO=R83w;p54l@BBX1IbMpXtE(bPe(Y7SjQaAs(21gBGCpOmOoI3Jw8> zGE%yNxs7lThX;8ABZ*2L1C}bWwIbm9F*!daHCd<%m|XHw5{pt8P9DAg_vjnV(3ABy za=a_{8H&7O)!3^4m%$^In<4D7t!{y9CSQ%-nvd&E)~%{hX>nv=NY0rv+u+-#EuH`W zn^sq6W=^mA<(qH*uy@8CO+yA_27QMA_xJBkzw@U&hv7)GoQQ-A6XTKf=T2P_Qd}}Q zdQN|=_p!o-M`P8Sf&%;cEmjxq*{EKiAC?)>Aala6oM+qBq zhA!fs*%^B8$IV6#F7CFjyPG-x|5wiGUAe2kd1a;T@gJqu>q-kZ?vhBD>iy>a?cKX? zPw{l0=#}+wnbfD6e#7XshHsu~iky;_`_``}mE4m#NmuBSMtsnmTaJFVlGd-Zj(?l5 zWVMkiksr!Pvany!dJ-IWJ3tp9( zoKIc3W4l4rC7|G^Q;%)Lmbth;-`UeuE$+r$YjWA)URlTIzFo_i*ffh<$%``?tBo1nl3Q+~iP24spaU#b>Dpf|dPONYSuE7;J z2{Un3nm{Tj-E6<_=e_UQ9^UOA9MgM|YI!hW3H>;n13AkW=m5cjRD_@nI87S&Jfnen zOvPBE<$1!ij7CYywWZjYaVDr_iav^19Oj@in13meKI%D!jmzT7E8-Fq?Fw*in22C# zp$d{q5%F;o!{MC!;y?iSc9*mDiH9Dz74bSu?A!Xuy#=qgKw-}`N!Rvpt;+%6(>MlY-mCbj5Oh{X6G@h+O|9x+ znUP=kZ4j~%oyHP$6tnP)`m&tv1+pM9^k2eNBb|BOOXRLWYZtZrhDGf&s6lt;mcAzH qBXc*~|4{v+wfy@*8nWQ%A(xbgRD^p^C(pMp@278%ul6E~Tlf?0${g+h literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-1 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-1 new file mode 100644 index 0000000000000000000000000000000000000000..92ac8436b926916bcfb5a189a9fbe609f718b724 GIT binary patch literal 990 zcmbVKJx|*}7&ayobV3L*A4`Tf(8kb^&5aK*wH<`*2sH|)vwaC}{SlonNCA1_H+1Z8 z=+?b^rT&Ia6~BOus&*6-H;HJ7Zh7zS`MCFauVH^&DQw|u8kJ+`iUj!K)h%Fy9sxB# zi4##5lt74snSI>DPIeg4ZW*Wb6)E?y7erxsDApw*p_q}3-tma<#-P@^eNsYAcy1^S zJ-r-xc_9NyX#zM>RETs*gA+*1s26r;QHJs%hw`H-jBaU2l4U5POw*X?%|*&kh2{d- zGwIw^%(Mk$n36eB{ZDuZ%@XItqbWLSN~)EAu03ER{-=9Qx>x|ETdIoc4NK3xvIWAv z?}Ie&QT&)vJV>MQ7zwgTjqbrPqju6R0he@e-)EqfF_U(ZAC^%+ftrLA`I&IDmfl(Q z_s|@J#xB|LXDo7`A!~GLZtAPTCRCTReF?RlY!3gv6S>6MxQQ7KT})kW{WSjl@a4zx zXWj~a{`s`ae_bhl+kNCt`aEYA3YP&6y$*?)U^|^kg{t^7rz#4u_D^l kL+8!gy?tTterJu_P8ZK{e38Ff<wW_bPr&DW2!i1dK$*q*nJ}nb9B{)PYZicp5U$EST9KD-X+Rcc7slP5n!_MN2KG z{RY}Mpc|KB_*)jG&rmdaZ*K0Z!yeS{XZt_YK~`P literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-3 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-3 new file mode 100644 index 0000000000000000000000000000000000000000..ded06463792438f031d063bb3c9ec234f756a22e GIT binary patch literal 990 zcmbVKJx|*}7`~WHQ742dgerzp2ZlH;jSDmqgNYAeVLKJJqY4yGXZsRd`6D`CkV52z zf5XCpn7ZUIbnMopQ+KwiwWB~>f+%IXyZ8Bc-{-xS^SM-hNlsZ@OWYG0lA9MJ$cKFj z8<0^qW*)4dm7}^{{{n;(Hjw*0HQ8NWreTQk*vgop7w@qu`B)xd38vy1IILr#;wrq|_9Pe2*Arr~DGHVR!H z!DtW!Fw1)yKVggvvuJ!y!+cZII-F$GNjp{O(JmPT95!-h+DVJcGMjrym$9lm5^g@y zj@{fx)*a~1C13uWMd35#gFc&^`D&<*wCCCW54DpnP5!S#OE`%@ODrqO*DFrWNXij}OQt6?U^hq(p?d;0qUC82g@ z=9MVb>L3)jdHT4<`#Ji$B9s)D6lLb6W2y@Fj6zbClaHpxFVr{Q(Z$8pB_3pEFv2{n zDqUQCTtkRZ8{ile;u!+;LVR$DV+g`j0)ZDFkEsz$@c4TA#fLfigd#gPsj?)s7{&L# zjuAwt@(cCxiFfu7^+R%Hv{GJaPL2{VyrIFLSX7i)2@IOdlGI#KOhM(9z+n_y8>^#~ zlA4xSnp2`=1=3j?TZVXi*pSxbu6*jf>A+E30;Nlg~2DlSRPOGzwBVMy%$HLpC#VpjOV^UJRV@0i4L zgi&Lw{$B=Q*y*2Jb85r#CXI& z3vfmfPC*UCI9k}JBTS0Jgb!4l*GEhp;UG$4bt*PsG2>XUg5D2UNK?={JpH4Dx^Uky zI(B|J^9o`Cvf3Q*!7w4RH4Dxmso+68SVTF-K?xNm_b|3+Ax+nzjtWg@uJ<5PhbD9% zf&HlMyM~*$fE-tI=c@k+51~ck1Mygfjk=oYm7nX61xx?x-qJoj0%d!qiP{~{F1_*) z#K&O>^1Ns9W6tq7k0uZ-Dke3%2h)stS+52t>*M24fL6iGdRci`PJ0(x8Zz{Mgj=+< zE9;_W#siqDsW6Or;<9MZ@zx} z_3~}&=4^X%F_bSW@2^&WOS_pY(Q5T`gyW#kQlZodrCX%Asnq>#s?-~PLuqc1HKoZK mKHXUN$vX3uwIA=Q(n`K$Ns_-;o literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-2 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-2 new file mode 100644 index 0000000000000000000000000000000000000000..75783b8a1cb5af3252c948eec6741ce60e330bc4 GIT binary patch literal 1043 zcmeZI%3@>@ODrqO*DFrWNXij}OQt6?U^hq(p?d;0qUC82g@ z=9MVb>L3)jdHT4<`#Ji$B9s)D6lLb6W2y@Fj6zbClaHpxFVr{Q(Z$8pB_3pEFv2{n zDqUQCTtkRZ8{ile;u!+;LVR$DV+g`j0)ZDFkEsz$@c4TA#fLfigd#gPsj?)s7{&L# zjuAwt@(cCxiFfu7^+R%Hv{GJaPL2{VyrIFLSX7i)2@IOdlGI#KOhM(9z+n_y8>^#~ zlA4xSnp2`=1=3j?TZVXi*pSxbu6*jf>A+E30;Nlg~2DlSRPOGzwBVK9z7BL95pPbPg8sdKrSm0Q?m zFllVn|I6SZ%fj%8T}Ekxx-5@^5Z~d9XotoSh3Hdx&gy0pw>?$s*V@N;C4S0;9HSXC zPE2lKQ)6`hWp{M-w774#g!SL%%-lEo>iT0o=Gsmf2LeDUT3mcW0vuH;mTW$vb7$7o wrPWV&RXT>Qzy0pby(qr-;$6>Wg!mFYnAjMY7BxgPxIb^5(Qq)GK?B`+00%T-TmS$7 literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-3 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-3 new file mode 100644 index 0000000000000000000000000000000000000000..e1c3a643fc26eee4991a71d8caee3a1027f11cd2 GIT binary patch literal 991 zcmbVKJ#W)M7{0hcL=_XNP$w##7&^p(w22@YkW74~7Pf<8J3>_9biTW!M*fJ-*Gg&S zg}=c+V1WU4W;Xr-jO>UF2|EgnX(}k)?(Tg)-uHR0@4u{6Z;@k>G*WuVBl6?MDU`D* zhg~Q*O$38=7?Wt_o=yoZ9uqNXkojw?F`k!DVR8;*dluGo9qG8xbe4J-B6VaU z_Y&Br+Q2p3d<5*cn!8l}M|c>o5-*6yGHg85Ot0LoKa)KDV|q(_b_ta2nI`V_J-gK9 z0gR8r5axL=;wM6oSsqOwc~op_QHS%4M%kzi86T6QP{MA(%tl#xSx#>sSsFI8QUi<#`>*LQ4m3Nix4|jip{Y(L@T740bI2iL(sx8XcecIVoTmA#4w%UGM?d;Hd rYKOOdw$t=!llyA(&7Ep(6Knzn0OeCfd9|hhWnBRuzwCmI^H#qA)lE5p literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-0 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-0 new file mode 100644 index 0000000000000000000000000000000000000000..e38b0902de6e6e1a21292e1c5eaa364402ee6f33 GIT binary patch literal 1051 zcmeZI%3@>@ODrqO*DFrWNXij}OQt6?U^hq(p?d;0qUC82g@ z=9MVb>L3)jdHT4<`#Ji$B9s)D6lLb6W2y@Fj6zbClaHpxFVr{Q(Z$8pB_3pEFv2{n zDqUQCTtkRZ8{ile;u!+;LVR$DV+g`j0)ZDFkEsz$@c4TA#fLfigd#gPsj?)s7{&L# zjuAwt@(cCxiFfu7^+R%Hv{GJaPL2{VyrIFLSX7i)2@IOdlGI#KOhM(9z+n_y8>^#~ zlA4xSnp2`=1=3j?TZVXi*pSxbu6*jf>A+E30;Nlg~2DlSRPOGzwBVc_3>;aA?x_`0cG;z2)ZZ^&`1 zVA9yC|ChldmWAOGyNuF=m6rcMNZ()oZ~tDIrxkV+la9RO@%TOYLfi3zj@5g$#eSdm zY?yYO$wi1)<(0Jf`=q^k`?S;E=gr+W`|9@NKIYk8nT=~~Dw+C%EoQ1u4KWf_d*x@? z6TkUZ$^Ha$^A)d3rROE)@E-ilrmQ5yy~1JvC&RC`0E1nMl;c1ut`D#svoC`bOl zehC-u`vIJ}A#vgtph?p-L{fD$P_!}R%WM1j@cX>(4EB~P%j7^L^_1@Ni2QhV2<2qV zVG9aQ6Tx5&#w1$Ur(;5k!$gegB(HaQeN2KViR)9b5s$ebk{9%0z(bb8*3RJ{CEP<@ z*X%g?<;*LHCCqAbz=mld?C3U{LsBV%c(jOe&FvB@OzvSE-^RLOAOjbg?p*Idq=78t zJp%hl?|P<}w}4$w_vWhq2oK{$;sf#6rh|LB<(Hp3m`I-9>E6~qKLX|WmWA6L-zmLv z2gdth2=lyW@e?7)B#$PLJSrwNyNA<^`dPmQ86T4UP{LNh%=%e*SZ;e0**Z3jzl2+~ z^wDo`A@3G+>rxDV!J_mTibkKz&3!G@L)O!5|A*Sos?)zu6UOQDuc;(4BZ4WttMk3? z(aUe?sQUBuuk|x0}88DzC mSpUG@tx}CMO4P>btBUd>UqDg7B>>j|@ODrqO*DFrWNXij}OQt6?U^hq(p?d;0qUC82g@ z=9MVb>L3)jdHT4<`#Ji$B9s)D6lLb6W2y@Fj6zbClaHpxFVr{Q(Z$8pB_3pEFv2{n zDqUQCTtkRZ8{ile;u!+;LVR$DV+g`j0)ZDFkEsz$@c4TA#fLfigd#gPsj?)s7{&L# zjuAwt@(cCxiFfu7^+R%Hv{GJaPL2{VyrIFLSX7i)2@IOdlGI#KOhM(9z+n_y8>^#~ zlA4xSnp2`=1=3j?TZVXi*pSxbu6*jf>A+E30;Nlg~2DlSRPOGzwBVOX(f_6|wwMN_ThovUv%spfM1 zVA9yC|ChmIE-S;OQ!45U)L+`)xT?AB`SgGBf1Y*pi>G*Ne%QaWI)BsCd*XktoM+fP zPa)n+a>fkHiIN`^-tCA_da@pGz;5JQgel+w~I|>NIqB~!k59}Fyp=T9`>)R zuIEW?T^;%>ZMA=IxOui_>cs*BLq@Sl3WCD?HXC?6W@v8~FyA(-q&{Y|@~W!4W$E98 xyeigD_#nj0QXY`N!p(4h=0}Bn4+G8ko?%0{~z}b!h+q literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-3 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/manifest/manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-3 new file mode 100644 index 0000000000000000000000000000000000000000..c4f747f590c59e07e8b7a3f6d95cb95e00fd06fd GIT binary patch literal 991 zcmbVKO>fgM81}3l5aKjdXxh;n7*bQV2G-GAXp9z-q-aShv?*Aw?RJ^+Q90hEGUbB! zL0q_V;$I+f;*2o_k2oO^_a;?o0jKe(Vo&M$

*Y$8%2sS*`^9Eq6csCRV!TZs(ufoBce zvbgYyQiY1v67bBjF>wtCFCn>-Q94;gdDdYK6=#<)Zr~8ZG_gr4O>e1pCDOz;_OF3` zVI26DUyeXL-|&~J{|JweRpJ%#IF?I>h8@(~9nF-;|Crt}US0#`2DVN5gTSqId4$r_ zI7VgOi}I~jjTP!u%pxr6%kujB*fEG@{w3UMq^Cju zIrc9=7cSNES1f9up&InY+|t*^Lu}v7_J62h(VYK%mT|$>U+0RZoJtNhA8ft-);YZY z>FdY58E%f?yS1(N4}XCD0s`J>yh>;qjYY1s&ZtYbna;Eh@9t`k=y*@t>*~6;{p2y< k*=4%mjA}b??txnyU;{t^;1>vgLI~h(2tIt)LG!ZJFR+t29smFU literal 0 HcmV?d00001 diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/schema/schema-0 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/schema/schema-0 new file mode 100644 index 000000000..d82dcea1a --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/schema/schema-0 @@ -0,0 +1,24 @@ +{ + "version" : 3, + "id" : 0, + "fields" : [ { + "id" : 0, + "name" : "id", + "type" : "INT NOT NULL" + }, { + "id" : 1, + "name" : "v", + "type" : "STRING" + } ], + "highestFieldId" : 1, + "partitionKeys" : [ ], + "primaryKeys" : [ "id" ], + "options" : { + "bucket" : "-1", + "owner" : "root", + "file.format" : "parquet", + "dynamic-bucket.target-row-num" : "2", + "deletion-vectors.enabled" : "true" + }, + "timeMillis" : 1792572933936 +} \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/EARLIEST b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/EARLIEST new file mode 100644 index 000000000..56a6051ca --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/EARLIEST @@ -0,0 +1 @@ +1 \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/LATEST b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/LATEST new file mode 100644 index 000000000..62f945751 --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/LATEST @@ -0,0 +1 @@ +6 \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-1 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-1 new file mode 100644 index 000000000..38a0c4c45 --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-1 @@ -0,0 +1,20 @@ +{ + "version" : 3, + "id" : 1, + "schemaId" : 0, + "baseManifestList" : "manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-0", + "baseManifestListSize" : 884, + "deltaManifestList" : "manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-1", + "deltaManifestListSize" : 990, + "changelogManifestList" : null, + "indexManifest" : "index-manifest-243d52b5-0cfc-4039-bf11-7436f05ebd99-0", + "commitUser" : "86f3fe45-aa7d-41e3-a32b-f49670b910da", + "commitIdentifier" : 9223372036854775807, + "commitKind" : "APPEND", + "timeMillis" : 1792572934818, + "logOffsets" : { }, + "totalRecordCount" : 5, + "deltaRecordCount" : 5, + "changelogRecordCount" : 0, + "nextRowId" : 0 +} \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-2 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-2 new file mode 100644 index 000000000..3715fb271 --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-2 @@ -0,0 +1,20 @@ +{ + "version" : 3, + "id" : 2, + "schemaId" : 0, + "baseManifestList" : "manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-2", + "baseManifestListSize" : 990, + "deltaManifestList" : "manifest-list-0014d5c7-8244-459c-ba6c-3e66042c6b22-3", + "deltaManifestListSize" : 990, + "changelogManifestList" : null, + "indexManifest" : "index-manifest-243d52b5-0cfc-4039-bf11-7436f05ebd99-0", + "commitUser" : "86f3fe45-aa7d-41e3-a32b-f49670b910da", + "commitIdentifier" : 9223372036854775807, + "commitKind" : "COMPACT", + "timeMillis" : 1792572934825, + "logOffsets" : { }, + "totalRecordCount" : 5, + "deltaRecordCount" : 0, + "changelogRecordCount" : 0, + "nextRowId" : 0 +} \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-3 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-3 new file mode 100644 index 000000000..7bf1cbf84 --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-3 @@ -0,0 +1,20 @@ +{ + "version" : 3, + "id" : 3, + "schemaId" : 0, + "baseManifestList" : "manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-0", + "baseManifestListSize" : 1001, + "deltaManifestList" : "manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-1", + "deltaManifestListSize" : 991, + "changelogManifestList" : null, + "indexManifest" : "index-manifest-243d52b5-0cfc-4039-bf11-7436f05ebd99-0", + "commitUser" : "b110fa6e-4595-43c0-b479-8756f91b126b", + "commitIdentifier" : 9223372036854775807, + "commitKind" : "APPEND", + "timeMillis" : 1792572936021, + "logOffsets" : { }, + "totalRecordCount" : 7, + "deltaRecordCount" : 2, + "changelogRecordCount" : 0, + "nextRowId" : 0 +} \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-4 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-4 new file mode 100644 index 000000000..122fa1de1 --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-4 @@ -0,0 +1,20 @@ +{ + "version" : 3, + "id" : 4, + "schemaId" : 0, + "baseManifestList" : "manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-2", + "baseManifestListSize" : 1043, + "deltaManifestList" : "manifest-list-19ad07c9-fcfc-4be6-b685-d6918922e81b-3", + "deltaManifestListSize" : 991, + "changelogManifestList" : null, + "indexManifest" : "index-manifest-243d52b5-0cfc-4039-bf11-7436f05ebd99-0", + "commitUser" : "b110fa6e-4595-43c0-b479-8756f91b126b", + "commitIdentifier" : 9223372036854775807, + "commitKind" : "COMPACT", + "timeMillis" : 1792572936030, + "logOffsets" : { }, + "totalRecordCount" : 5, + "deltaRecordCount" : -2, + "changelogRecordCount" : 0, + "nextRowId" : 0 +} \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-5 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-5 new file mode 100644 index 000000000..f01ce92b2 --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-5 @@ -0,0 +1,20 @@ +{ + "version" : 3, + "id" : 5, + "schemaId" : 0, + "baseManifestList" : "manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-0", + "baseManifestListSize" : 1051, + "deltaManifestList" : "manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-1", + "deltaManifestListSize" : 991, + "changelogManifestList" : null, + "indexManifest" : "index-manifest-243d52b5-0cfc-4039-bf11-7436f05ebd99-0", + "commitUser" : "9b190bb7-7a17-4f78-9035-60a019950355", + "commitIdentifier" : 9223372036854775807, + "commitKind" : "APPEND", + "timeMillis" : 1792572937421, + "logOffsets" : { }, + "totalRecordCount" : 7, + "deltaRecordCount" : 2, + "changelogRecordCount" : 0, + "nextRowId" : 0 +} \ No newline at end of file diff --git a/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-6 b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-6 new file mode 100644 index 000000000..7d9f5c370 --- /dev/null +++ b/test/test_data/parquet/pk_dynamic_bucket_dv.db/pk_dynamic_bucket_dv/snapshot/snapshot-6 @@ -0,0 +1,20 @@ +{ + "version" : 3, + "id" : 6, + "schemaId" : 0, + "baseManifestList" : "manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-2", + "baseManifestListSize" : 1091, + "deltaManifestList" : "manifest-list-51b6b5dd-86de-4a97-9a90-86dc8382f85e-3", + "deltaManifestListSize" : 991, + "changelogManifestList" : null, + "indexManifest" : "index-manifest-243d52b5-0cfc-4039-bf11-7436f05ebd99-0", + "commitUser" : "9b190bb7-7a17-4f78-9035-60a019950355", + "commitIdentifier" : 9223372036854775807, + "commitKind" : "COMPACT", + "timeMillis" : 1792572937428, + "logOffsets" : { }, + "totalRecordCount" : 3, + "deltaRecordCount" : -4, + "changelogRecordCount" : 0, + "nextRowId" : 0 +} \ No newline at end of file