branch-3.0: [Improvement](tools) refine tools schema apache#45778 (ap…

…ache#45801) Cherry-picked from apache#45778 Co-authored-by: xzj7019 <[email protected]>
924060929 · Dec 23, 2024 · 8f1dc58 · 8f1dc58
1 parent fc0a020
commit 8f1dc58
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 16 deletions.
diff --git a/tools/tpcds-tools/ddl/create-tpcds-tables-sf1000.sql b/tools/tpcds-tools/ddl/create-tpcds-tables-sf1000.sql
@@ -213,7 +213,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(cs_item_sk, cs_order_number) BUCKETS 3
+DISTRIBUTED BY HASH(cs_item_sk, cs_order_number) BUCKETS 4
 PROPERTIES (
   "replication_num" = "1"
 );
@@ -339,7 +339,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(inv_item_sk, inv_warehouse_sk) BUCKETS 1
+DISTRIBUTED BY HASH(inv_item_sk, inv_warehouse_sk) BUCKETS 2
 PROPERTIES (
   "replication_num" = "1"
 );
@@ -449,7 +449,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(cr_item_sk, cr_order_number) BUCKETS 1
+DISTRIBUTED BY HASH(cr_item_sk, cr_order_number) BUCKETS 2
 PROPERTIES (
   "replication_num" = "1"
 );
@@ -648,7 +648,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(wr_item_sk, wr_order_number) BUCKETS 1
+DISTRIBUTED BY HASH(wr_item_sk, wr_order_number) BUCKETS 2
 PROPERTIES (
   "replication_num" = "1"
 );
@@ -826,7 +826,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(ws_item_sk, ws_order_number) BUCKETS 3
+DISTRIBUTED BY HASH(ws_item_sk, ws_order_number) BUCKETS 2
 PROPERTIES (
   "replication_num" = "1"
 );
@@ -1006,7 +1006,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(sr_item_sk, sr_ticket_number) BUCKETS 1
+DISTRIBUTED BY HASH(sr_item_sk, sr_ticket_number) BUCKETS 2
 PROPERTIES (
   "replication_num" = "1"
 );
@@ -1112,7 +1112,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(ss_item_sk, ss_ticket_number) BUCKETS 3
+DISTRIBUTED BY HASH(ss_item_sk, ss_ticket_number) BUCKETS 4
 PROPERTIES (
   "replication_num" = "1"
 );

diff --git a/tools/tpcds-tools/ddl/create-tpcds-tables-sf10000.sql b/tools/tpcds-tools/ddl/create-tpcds-tables-sf10000.sql
@@ -213,7 +213,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(cs_item_sk, cs_order_number) BUCKETS 256
+DISTRIBUTED BY HASH(cs_item_sk, cs_order_number) BUCKETS 216
 PROPERTIES (
   "replication_num" = "1",
   "colocate_with" = "catalog"
@@ -340,7 +340,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(inv_item_sk, inv_warehouse_sk) BUCKETS 256
+DISTRIBUTED BY HASH(inv_item_sk, inv_warehouse_sk) BUCKETS 216
 PROPERTIES (
   "replication_num" = "1"
 );
@@ -450,7 +450,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(cr_item_sk, cr_order_number) BUCKETS 256
+DISTRIBUTED BY HASH(cr_item_sk, cr_order_number) BUCKETS 216
 PROPERTIES (
   "replication_num" = "1",
   "colocate_with" = "catalog"
@@ -485,7 +485,7 @@ CREATE TABLE IF NOT EXISTS customer_address (
     ca_location_type char(20)
 )
 DUPLICATE KEY(ca_address_sk)
-DISTRIBUTED BY HASH(ca_address_sk) BUCKETS 256
+DISTRIBUTED BY HASH(ca_address_sk) BUCKETS 216
 PROPERTIES (
   "replication_num" = "1"
 );
@@ -650,7 +650,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(wr_item_sk, wr_order_number) BUCKETS 256
+DISTRIBUTED BY HASH(wr_item_sk, wr_order_number) BUCKETS 216
 PROPERTIES (
   "replication_num" = "1",
   "colocate_with" = "web"
@@ -829,7 +829,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(ws_item_sk, ws_order_number) BUCKETS 256
+DISTRIBUTED BY HASH(ws_item_sk, ws_order_number) BUCKETS 216
 PROPERTIES (
   "replication_num" = "1",
   "colocate_with" = "web"
@@ -1010,7 +1010,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(sr_item_sk, sr_ticket_number) BUCKETS 256
+DISTRIBUTED BY HASH(sr_item_sk, sr_ticket_number) BUCKETS 216
 PROPERTIES (
   "replication_num" = "1",
   "colocate_with" = "store"
@@ -1117,7 +1117,7 @@ PARTITION `p70` VALUES LESS THAN ("2452945"),
 PARTITION `p71` VALUES LESS THAN ("2452975"),
 PARTITION `p72` VALUES LESS THAN (MAXVALUE)
 )
-DISTRIBUTED BY HASH(ss_item_sk, ss_ticket_number) BUCKETS 256
+DISTRIBUTED BY HASH(ss_item_sk, ss_ticket_number) BUCKETS 216
 PROPERTIES (
   "replication_num" = "1",
   "colocate_with" = "store"
@@ -1158,7 +1158,7 @@ CREATE TABLE IF NOT EXISTS customer (
     c_last_review_date_sk integer
 )
 DUPLICATE KEY(c_customer_sk)
-DISTRIBUTED BY HASH(c_customer_id) BUCKETS 256
+DISTRIBUTED BY HASH(c_customer_id) BUCKETS 216
 PROPERTIES (
   "replication_num" = "1"
 );