Skip to content

Commit

Permalink
[test](auto partition)add auto partitions p2 case (apache#31202)
Browse files Browse the repository at this point in the history
  • Loading branch information
zfr9527 authored Feb 21, 2024
1 parent 3f8ab03 commit 2ff0339
Show file tree
Hide file tree
Showing 21 changed files with 1,293 additions and 35 deletions.
Original file line number Diff line number Diff line change
@@ -1,21 +1,21 @@
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.

tables:
stress_source:
create_date:
range: {min: "2023-07-01", max: "2024-01-10"}
stress_source:
create_date:
range: {min: "2023-07-01", max: "2024-01-10"}
Original file line number Diff line number Diff line change
@@ -1,19 +1,19 @@
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.

tables:
small_data_high_concurrent_load_range:
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,46 @@
CREATE TABLE `test2`(
`col1` bigint not null,
`col2` boolean,
`col3` tinyint,
`col4` date,
`col5` float,
`col6` double,
`col7` string,
`col8` varchar(128),
`col9` decimal(9, 3),
`col10` char(128),
`col11` bigint,
`col12` boolean,
`col13` tinyint,
`col14` date,
`col15` float,
`col16` double,
`col17` string,
`col18` varchar(128),
`col19` decimal(9, 3),
`col20` char(128),
`col21` bigint,
`col22` boolean,
`col23` tinyint,
`col24` date,
`col25` float,
`col26` double,
`col27` string,
`col28` varchar(128),
`col29` decimal(9, 3),
`col30` char(128),
`col31` bigint,
`col32` boolean,
`col33` tinyint,
`col34` date,
`col35` float,
`col36` double,
`col37` string,
`col38` varchar(128),
`col39` decimal(9, 3),
`col40` char(128)
) UNIQUE KEY(`col1`)
DISTRIBUTED BY HASH(`col1`) BUCKETS 10
PROPERTIES (
"replication_num" = "1"
);
Original file line number Diff line number Diff line change
@@ -0,0 +1,46 @@
CREATE TABLE `test1`(
`col1` date not null,
`col2` boolean,
`col3` tinyint,
`col4` date,
`col5` float,
`col6` double,
`col7` string,
`col8` varchar(128),
`col9` decimal(9, 3),
`col10` char(128),
`col11` bigint,
`col12` boolean,
`col13` tinyint,
`col14` date,
`col15` float,
`col16` double,
`col17` string,
`col18` varchar(128),
`col19` decimal(9, 3),
`col20` char(128),
`col21` bigint,
`col22` boolean,
`col23` tinyint,
`col24` date,
`col25` float,
`col26` double,
`col27` string,
`col28` varchar(128),
`col29` decimal(9, 3),
`col30` char(128),
`col31` bigint,
`col32` boolean,
`col33` tinyint,
`col34` date,
`col35` float,
`col36` double,
`col37` string,
`col38` varchar(128),
`col39` decimal(9, 3),
`col40` char(128)
) UNIQUE KEY(`col1`)
DISTRIBUTED BY HASH(`col1`) BUCKETS 10
PROPERTIES (
"replication_num" = "1"
);
Original file line number Diff line number Diff line change
@@ -0,0 +1,13 @@
CREATE TABLE `small_data_high_concurrent_load_range`(
`col1` datetimev2 not null,
`col2` varchar(128),
`col3` decimal(9, 3),
`col4` date
) duplicate KEY(`col1`)
AUTO PARTITION BY range date_trunc(`col1`, 'day')
(
)
DISTRIBUTED BY HASH(`col1`) BUCKETS 10
PROPERTIES (
"replication_num" = "1"
);
Original file line number Diff line number Diff line change
@@ -0,0 +1,49 @@
CREATE TABLE `stream_load_list_test_table`(
`col1` bigint not null,
`col2` boolean,
`col3` tinyint,
`col4` date,
`col5` float,
`col6` double,
`col7` string,
`col8` varchar(128),
`col9` decimal(9, 3),
`col10` char(128),
`col11` bigint,
`col12` boolean,
`col13` tinyint,
`col14` date,
`col15` float,
`col16` double,
`col17` string,
`col18` varchar(128),
`col19` decimal(9, 3),
`col20` char(128),
`col21` bigint,
`col22` boolean,
`col23` tinyint,
`col24` date,
`col25` float,
`col26` double,
`col27` string,
`col28` varchar(128),
`col29` decimal(9, 3),
`col30` char(128),
`col31` bigint,
`col32` boolean,
`col33` tinyint,
`col34` date,
`col35` float,
`col36` double,
`col37` string,
`col38` varchar(128),
`col39` decimal(9, 3),
`col40` char(128)
) UNIQUE KEY(`col1`)
AUTO PARTITION BY list(`col1`)
(
)
DISTRIBUTED BY HASH(`col1`) BUCKETS 10
PROPERTIES (
"replication_num" = "1"
);
Original file line number Diff line number Diff line change
@@ -0,0 +1,49 @@
CREATE TABLE `stream_load_range_test_table`(
`col1` datetimev2 not null,
`col2` boolean,
`col3` tinyint,
`col4` date,
`col5` float,
`col6` double,
`col7` string,
`col8` varchar(128),
`col9` decimal(9, 3),
`col10` char(128),
`col11` bigint,
`col12` boolean,
`col13` tinyint,
`col14` date,
`col15` float,
`col16` double,
`col17` string,
`col18` varchar(128),
`col19` decimal(9, 3),
`col20` char(128),
`col21` bigint,
`col22` boolean,
`col23` tinyint,
`col24` date,
`col25` float,
`col26` double,
`col27` string,
`col28` varchar(128),
`col29` decimal(9, 3),
`col30` char(128),
`col31` bigint,
`col32` boolean,
`col33` tinyint,
`col34` date,
`col35` float,
`col36` double,
`col37` string,
`col38` varchar(128),
`col39` decimal(9, 3),
`col40` char(128)
) UNIQUE KEY(`col1`)
AUTO PARTITION BY range date_trunc(`col1`, 'day')
(
)
DISTRIBUTED BY HASH(`col1`) BUCKETS 10
PROPERTIES (
"replication_num" = "1"
);
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
CREATE TABLE `two_streamload_list1`(
`col1` bigint not null,
`col5` bigint,
`col2` boolean,
`col3` tinyint,
`col4` date
) DUPLICATE KEY(`col1`)
AUTO PARTITION BY list(`col1`)
(
)
DISTRIBUTED BY HASH(`col1`) BUCKETS 10
PROPERTIES (
"replication_num" = "1"
);
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
CREATE TABLE `two_streamload_list2`(
`col1` bigint not null,
`col5` bigint,
`col2` boolean,
`col3` tinyint,
`col4` date
) DUPLICATE KEY(`col1`)
AUTO PARTITION BY list(`col1`)
(
)
DISTRIBUTED BY HASH(`col1`) BUCKETS 10
PROPERTIES (
"replication_num" = "1"
);
Loading

0 comments on commit 2ff0339

Please sign in to comment.