Skip to content

Commit

Permalink
[feature](MultiPartition)user could modify multi partition prefix(apa…
Browse files Browse the repository at this point in the history
  • Loading branch information
felixwluo authored Apr 20, 2024
1 parent 5c2fca8 commit 83ac44b
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand All @@ -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<String, String> properties) throws AnalysisException {
Expand Down

0 comments on commit 83ac44b

Please sign in to comment.