diff --git a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeConfig.java b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeConfig.java index 87ff4190d60f..acef9be6c522 100644 --- a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeConfig.java +++ b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeConfig.java @@ -271,13 +271,13 @@ public long getDefaultCheckpointWritingInterval() return defaultCheckpointWritingInterval; } - public boolean isCheckpointPartitionFilterEnabled() + public boolean isCheckpointFilteringEnabled() { return checkpointFilteringEnabled; } @Config("delta.checkpoint-filtering.enabled") - public DeltaLakeConfig setCheckpointPartitionFilterEnabled(boolean checkpointFilteringEnabled) + public DeltaLakeConfig setCheckpointFilteringEnabled(boolean checkpointFilteringEnabled) { this.checkpointFilteringEnabled = checkpointFilteringEnabled; return this; diff --git a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeSessionProperties.java b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeSessionProperties.java index 8cfb02a3988b..7b779e053a17 100644 --- a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeSessionProperties.java +++ b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeSessionProperties.java @@ -201,7 +201,7 @@ public DeltaLakeSessionProperties( booleanProperty( CHECKPOINT_FILTERING_ENABLED, "Use filter in checkpoint reader", - deltaLakeConfig.isCheckpointPartitionFilterEnabled(), + deltaLakeConfig.isCheckpointFilteringEnabled(), false)); } diff --git a/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeConfig.java b/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeConfig.java index 4a6306dc524f..dc42d2aba812 100644 --- a/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeConfig.java +++ b/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeConfig.java @@ -53,7 +53,7 @@ public void testDefaults() .setMaxPartitionsPerWriter(100) .setUnsafeWritesEnabled(false) .setDefaultCheckpointWritingInterval(10) - .setCheckpointPartitionFilterEnabled(false) + .setCheckpointFilteringEnabled(false) .setCheckpointRowStatisticsWritingEnabled(true) .setVacuumMinRetention(new Duration(7, DAYS)) .setHiveCatalogName(null) @@ -125,7 +125,7 @@ public void testExplicitPropertyMappings() .setUnsafeWritesEnabled(true) .setDefaultCheckpointWritingInterval(15) .setCheckpointRowStatisticsWritingEnabled(false) - .setCheckpointPartitionFilterEnabled(true) + .setCheckpointFilteringEnabled(true) .setVacuumMinRetention(new Duration(13, HOURS)) .setHiveCatalogName("hive") .setDynamicFilteringWaitTimeout(new Duration(30, MINUTES))