From 83ac44b9d05acc6df07d7cec0e0889d2d2681acb Mon Sep 17 00:00:00 2001 From: lw112 <131352377+felixwluo@users.noreply.github.com> Date: Sat, 20 Apr 2024 20:22:38 +0800 Subject: [PATCH] [feature](MultiPartition)user could modify multi partition prefix(#33898) --- .../src/main/java/org/apache/doris/common/Config.java | 8 ++++++++ .../org/apache/doris/analysis/MultiPartitionDesc.java | 3 ++- 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java index c7ffdae5214893..e099f4567b92e0 100644 --- a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java +++ b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java @@ -1411,6 +1411,14 @@ public class Config extends ConfigBase { @ConfField(mutable = true, masterOnly = true) public static int max_multi_partition_num = 4096; + /** + * Use this parameter to set the partition name prefix for multi partition, + * Only multi partition takes effect, not dynamic partitions. + * The default prefix is "p". + */ + @ConfField(mutable = true, masterOnly = true) + public static String multi_partition_name_prefix = "p"; + /** * Control the max num of backup/restore job per db */ diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java index 8423acc83d87d8..b8711f61ee60d9 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java @@ -49,7 +49,6 @@ public class MultiPartitionDesc implements AllPartitionDesc { public static final String DATETIME_FORMAT = "yyyy-MM-dd HH:mm:ss"; - private final String partitionPrefix = "p"; private LocalDateTime startTime; private LocalDateTime endTime; @@ -75,6 +74,8 @@ public class MultiPartitionDesc implements AllPartitionDesc { ); private final Integer maxAllowedLimit = Config.max_multi_partition_num; + //multi_partition_name_prefix default: p + private final String partitionPrefix = Config.multi_partition_name_prefix; public MultiPartitionDesc(PartitionKeyDesc partitionKeyDesc, Map properties) throws AnalysisException {