Skip to content

Commit 00a1354

Browse files
committed
make a few values final
1 parent 3dfedae commit 00a1354

1 file changed

Lines changed: 8 additions & 8 deletions

File tree

IoTDBJDBC/src/main/java/com/oracle/demo/timg/iot/iotdbjdbc/dataread/filereader/NormalizedDataFileInput.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -84,11 +84,11 @@ public class NormalizedDataFileInput implements IoTDBClient, Runnable {
8484
@ToString.Include
8585
private final String sourceFilename;
8686
@ToString.Include
87-
private Duration replayStartOffset;
87+
private final Duration replayStartOffset;
8888
@ToString.Include
89-
private Duration replayDuration;
89+
private final Duration replayDuration;
9090
@ToString.Include
91-
private ZonedDateTime replayEndTimeObserved;
91+
private final ZonedDateTime replayEndTimeObserved;
9292
@ToString.Include
9393
private final FileDataInputMode mode;
9494
@ToString.Include
@@ -194,7 +194,7 @@ public void configureDBClient(String filteringRule) throws DateTimeParseExceptio
194194
// then we've fallen off the end of the input stream, so need to error
195195
ZonedDateTime readZDT = startZDT;
196196
while ((readZDT != null) && (readZDT.isBefore(startOffsetZDT))) {
197-
log.info("Discarding entry " + nextDataToSend + " as it's before the start point");
197+
log.finer("Discarding entry " + nextDataToSend + " as it's before the start point");
198198
try {
199199
nextDataToSend = readNormalizedDataFileVersionFromInput(inputReader);
200200
readZDT = getTimeObservedFromNormalizedDataFileVersion(nextDataToSend);
@@ -300,7 +300,7 @@ public void run() {
300300
log.info("nextDataToSend is null, stopping processing");
301301
}
302302

303-
log.info(() -> "Running a send cycle on " + nextDataToSend);
303+
log.fine(() -> "Running a send cycle on " + nextDataToSend);
304304
// the timestamp was extracted when the nextDataToSend was setup, but just for
305305
// defensive reasons
306306
if (nextDataToSendTimeStamp == null) {
@@ -315,15 +315,15 @@ public void run() {
315315
"Programming error, this should not have happened, conversion of NormalizedDataFromNormalized to NormalizedData returned null, stopping processing");
316316
return;
317317
}
318-
log.info(() -> "Extracted NormalizedData pre time adjustment is " + normalizedData);
318+
log.finer(() -> "Extracted NormalizedData pre time adjustment is " + normalizedData);
319319
// depending on the mode we need to replace the timestamp with the current time
320320
// or work out an offset for it
321321
ZonedDateTime timeToSet = switch (this.mode) {
322322
case REAL_TIME -> ZonedDateTime.now(UTC_TZ);
323323
case HIGH_SPEED -> nextDataToSendTimeStamp.plus(highSpeedOffset);
324324
};
325325
normalizedData.setTimeObserved(timeToSet.format(dateTimeFormatter));
326-
log.info(() -> "Extracted NormalizedData tiemObserved after time adjustment is "
326+
log.finer(() -> "Extracted NormalizedData tiemObserved after time adjustment is "
327327
+ normalizedData.getTimeObserved() + " Sending to message handlers");
328328
// OK, got it all, let's send it
329329
normalizedDataMessageHandlerService.handle(normalizedData);
@@ -370,7 +370,7 @@ public void run() {
370370
delayDuration = Duration.ZERO;
371371
}
372372
Duration tmpDuration = delayDuration;
373-
log.info(() -> "duration to next upload run is " + tmpDuration + " (mode = " + mode + ")");
373+
log.finer(() -> "duration to next upload run is " + tmpDuration + " (mode = " + mode + ")");
374374
// move the saved data along
375375
nextDataToSend = followingNormalizedDataFileVersion;
376376
nextDataToSendTimeStamp = followingNormalizedDataFileVersionTimeObserved;

0 commit comments

Comments
 (0)