Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -64,19 +64,21 @@ public DistributionInfoType getType() {
}

public int getBucketNum() {
// should override in sub class
throw new NotImplementedException("not implemented");
return bucketNum;
}

public void setBucketNum(int bucketNum) {
// should override in sub class
throw new NotImplementedException("not implemented");
this.bucketNum = bucketNum;
}

public void markAutoBucket() {
autoBucket = true;
}

public void setAutoBucket(boolean autoBucket) {
this.autoBucket = autoBucket;
}

public DistributionDesc toDistributionDesc() {
throw new NotImplementedException("toDistributionDesc not implemented");
}
Expand Down
4 changes: 4 additions & 0 deletions fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
Original file line number Diff line number Diff line change
Expand Up @@ -6202,6 +6202,8 @@ public void modifyDefaultDistributionBucketNum(Database db, OlapTable olapTable,
}

defaultDistributionInfo.setBucketNum(bucketNum);
defaultDistributionInfo.setAutoBucket(distributionInfo.getAutoBucket());
olapTable.setIsAutoBucket(distributionInfo.getAutoBucket());

ModifyTableDefaultDistributionBucketNumOperationLog info
= new ModifyTableDefaultDistributionBucketNumOperationLog(db.getId(), olapTable.getId(),
Expand All @@ -6227,6 +6229,8 @@ public void replayModifyTableDefaultDistributionBucketNum(ModifyTableDefaultDist
try {
DistributionInfo defaultDistributionInfo = olapTable.getDefaultDistributionInfo();
defaultDistributionInfo.setBucketNum(bucketNum);
defaultDistributionInfo.setAutoBucket(info.getAutoBucket());
olapTable.setIsAutoBucket(info.getAutoBucket());
} finally {
olapTable.writeUnlock();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,16 +54,6 @@ public List<Column> getDistributionColumns() {
return distributionColumns;
}

@Override
public int getBucketNum() {
return bucketNum;
}

@Override
public void setBucketNum(int bucketNum) {
this.bucketNum = bucketNum;
}

public boolean sameDistributionColumns(HashDistributionInfo other) {
if (distributionColumns.size() != other.distributionColumns.size()) {
return false;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,11 +44,6 @@ public DistributionDesc toDistributionDesc() {
return distributionDesc;
}

@Override
public int getBucketNum() {
return bucketNum;
}

@Override
public String getColumnsName() {
return "";
Expand Down
Loading
Loading