Skip to content

Commit d31a63a

Browse files
committed
rename
1 parent 94c5703 commit d31a63a

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3070,7 +3070,7 @@ public int getPartitionTTLEventTimeSegmentStartIndex() {
30703070
return getIntOrDefault(HoodieTTLConfig.EVENT_TIME_SEGMENT_START_INDEX);
30713071
}
30723072

3073-
public boolean getPartitionTTLEventTimeDeleteHiveDefaultPartition() {
3073+
public boolean shouldPartitionTTLEventTimeDeleteHiveDefaultPartition() {
30743074
return getBooleanOrDefault(HoodieTTLConfig.EVENT_TIME_DELETE_HIVE_DEFAULT_PARTITION);
30753075
}
30763076

hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/KeepByEventTimeStrategy.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ public class KeepByEventTimeStrategy extends KeepByTimeStrategy {
129129

130130
private final String eventTimeFormat;
131131
private final int timeSegStartIndex;
132-
private final boolean deleteHiveDefaultPartition;
132+
private final boolean shouldDeleteHiveDefaultPartition;
133133
private final boolean hiveStylePartitioning;
134134

135135
public KeepByEventTimeStrategy(HoodieTable hoodieTable, String instantTime) {
@@ -146,7 +146,7 @@ public KeepByEventTimeStrategy(HoodieTable hoodieTable, String instantTime) {
146146
throw new IllegalArgumentException(
147147
HoodieTTLConfig.EVENT_TIME_SEGMENT_START_INDEX.key() + " must be >= 0, got " + timeSegStartIndex);
148148
}
149-
this.deleteHiveDefaultPartition = writeConfig.getPartitionTTLEventTimeDeleteHiveDefaultPartition();
149+
this.shouldDeleteHiveDefaultPartition = writeConfig.shouldPartitionTTLEventTimeDeleteHiveDefaultPartition();
150150
// Hive-style partitioning is a table-level property recorded at table creation; trust it
151151
// rather than guessing per-segment from a stray '=' character in a value.
152152
this.hiveStylePartitioning = Boolean.parseBoolean(
@@ -160,7 +160,7 @@ protected List<String> getExpiredPartitionsForTimeStrategy(List<String> partitio
160160
int segCount = segmentCount(eventTimeFormat);
161161
return partitionPathsForTTL.stream().parallel()
162162
.filter(path -> isPartitionExpiredByEventTime(
163-
path, formatter, timeSegStartIndex, segCount, cutoffMillis, deleteHiveDefaultPartition, hiveStylePartitioning))
163+
path, formatter, timeSegStartIndex, segCount, cutoffMillis, shouldDeleteHiveDefaultPartition, hiveStylePartitioning))
164164
.collect(Collectors.toList());
165165
}
166166

0 commit comments

Comments
 (0)