Skip to content

Commit

Permalink
1
Browse files Browse the repository at this point in the history
  • Loading branch information
askwang committed Jan 14, 2025
1 parent 86147b4 commit 16e2bec
Showing 1 changed file with 4 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -52,9 +52,11 @@ public static Map<String, String> fillInPartitionOptions(
dynamicOptions, CoreOptions.PARTITION_TIMESTAMP_PATTERN.key(), timestampPattern);
setTableOptions(
dynamicOptions, CoreOptions.PARTITION_EXPIRATION_TIME.key(), expirationTime);
setTableOptions(dynamicOptions, CoreOptions.PARTITION_EXPIRATION_MAX_NUM.key(), maxExpires);
setTableOptions(dynamicOptions, CoreOptions.PARTITION_EXPIRATION_CHECK_INTERVAL.key(), "0");

if (maxExpires != null) {
dynamicOptions.put(
CoreOptions.PARTITION_EXPIRATION_MAX_NUM.key(), String.valueOf(maxExpires));
}
return dynamicOptions;
}

Expand All @@ -65,13 +67,6 @@ private static void setTableOptions(
}
}

private static void setTableOptions(
HashMap<String, String> dynamicOptions, String key, Integer value) {
if (value != null) {
dynamicOptions.put(key, String.valueOf(value));
}
}

public static ExpireConfig.Builder fillInSnapshotOptions(
CoreOptions tableOptions,
Integer retainMax,
Expand Down

0 comments on commit 16e2bec

Please sign in to comment.