Formatting cleanup using gradlew spotnessApply.

mransley · Dec 2, 2019 · 2021531 · 2021531
1 parent 1763fd8
commit 2021531
Showing 1 changed file with 16 additions and 12 deletions.
diff --git a/...aflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java b/...aflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java
@@ -1102,19 +1102,23 @@ private <T> void translateTyped(TestStream<T> transform, TranslationContext cont
  }
  payloadBuilder.addEventsBuilder().setElementEvent(addElementsBuilder);
  } else if (event instanceof TestStream.WatermarkEvent) {
- payloadBuilder.addEventsBuilder().setWatermarkEvent(
- RunnerApi.TestStreamPayload.Event.AdvanceWatermark.newBuilder()
- .setNewWatermark(
- ((TestStream.WatermarkEvent) event).getWatermark().getMillis()
- * 1000));
+ payloadBuilder
+ .addEventsBuilder()
+ .setWatermarkEvent(
+ RunnerApi.TestStreamPayload.Event.AdvanceWatermark.newBuilder()
+ .setNewWatermark(
+ ((TestStream.WatermarkEvent) event).getWatermark().getMillis()
+ * 1000));
  } else if (event instanceof TestStream.ProcessingTimeEvent) {
- payloadBuilder.addEventsBuilder().setProcessingTimeEvent(
- RunnerApi.TestStreamPayload.Event.AdvanceProcessingTime.newBuilder()
- .setAdvanceDuration(
- ((TestStream.ProcessingTimeEvent) event)
- .getProcessingTimeAdvance()
- .getMillis()
- * 1000));
+ payloadBuilder
+ .addEventsBuilder()
+ .setProcessingTimeEvent(
+ RunnerApi.TestStreamPayload.Event.AdvanceProcessingTime.newBuilder()
+ .setAdvanceDuration(
+ ((TestStream.ProcessingTimeEvent) event)
+ .getProcessingTimeAdvance()
+ .getMillis()
+ * 1000));
  }
  }
  stepContext.addInput(