Rename DEFAULT_ROLLOVER_TIME_MILLISECONDS to DEFAULT_ROLLOVER_CHECK_I…

…NTERVAL_DURATION (#7) A leftover from #4
google · Dec 13, 2022 · 50d8e74 · 50d8e74
1 parent ed97cdb
commit 50d8e74
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/java/com/google/cloud/bigquery/dwhassessment/hooks/logger/EventLogger.java b/src/java/com/google/cloud/bigquery/dwhassessment/hooks/logger/EventLogger.java
@@ -39,7 +39,7 @@ public class EventLogger {
   private static final int MAX_RETRIES = 2;
   private static final Duration SHUTDOWN_WAIT_TIME = Duration.ofSeconds(5);
   private static final int QUERY_EVENTS_QUEUE_DEFAULT_SIZE = 64;
-  private static final Duration DEFAULT_ROLLOVER_TIME_MILLISECONDS = Duration.ofSeconds(600);
+  private static final Duration DEFAULT_ROLLOVER_CHECK_INTERVAL_DURATION = Duration.ofMinutes(10);
 
   private final DatePartitionedRecordsWriterFactory logger;
   private final EventRecordConstructor eventRecordConstructor;
@@ -97,7 +97,7 @@ protected EventLogger(HiveConf conf, Clock clock) {
     long rolloverIntervalMilliseconds =
         conf.getTimeDuration(
             HIVE_QUERY_EVENTS_ROLLOVER_CHECK_INTERVAL.getConfName(),
-            DEFAULT_ROLLOVER_TIME_MILLISECONDS.toMillis(),
+            DEFAULT_ROLLOVER_CHECK_INTERVAL_DURATION.toMillis(),
             TimeUnit.MILLISECONDS);
 
     logWriter.scheduleWithFixedDelay(