spotless.

Author: stankiewicz

sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java

@@ -497,7 +497,8 @@ public <T> void output(TupleTag<T> tag, T output, Instant timestamp, BoundedWind
                       PaneInfo.NO_FIRING,
                       null,
                       null,
-                      CausedByDrain.NORMAL, null));
+                      CausedByDrain.NORMAL,
+                      null));
         }
       };
     }
@@ -641,7 +642,8 @@ public <T> void outputWithTimestamp(TupleTag<T> tag, T output, Instant timestamp
                   element.getPaneInfo(),
                   null,
                   null,
-                  CausedByDrain.NORMAL, null));
+                  CausedByDrain.NORMAL,
+                  null));
     }
 
     @Override

sdks/java/core/src/main/java/org/apache/beam/sdk/values/ValueInSingleWindow.java

@@ -82,7 +82,14 @@ public static <T> ValueInSingleWindow<T> of(
       CausedByDrain causedByDrain,
       @Nullable Context openTelemetryContext) {
     return new AutoValue_ValueInSingleWindow<>(
-        value, timestamp, window, paneInfo, currentRecordId, currentRecordOffset, causedByDrain, openTelemetryContext);
+        value,
+        timestamp,
+        window,
+        paneInfo,
+        currentRecordId,
+        currentRecordOffset,
+        causedByDrain,
+        openTelemetryContext);
   }
 
   public static <T> ValueInSingleWindow<T> of(
@@ -116,7 +123,8 @@ public void encode(ValueInSingleWindow<T> windowedElem, OutputStream outStream)
     }
 
     @Override
-    public void encode(ValueInSingleWindow<T> windowedElem, OutputStream outStream, Coder.Context context)
+    public void encode(
+        ValueInSingleWindow<T> windowedElem, OutputStream outStream, Coder.Context context)
         throws IOException {
       InstantCoder.of().encode(windowedElem.getTimestamp(), outStream);
       windowCoder.encode(windowedElem.getWindow(), outStream);
@@ -153,7 +161,7 @@ public ValueInSingleWindow<T> decode(InputStream inStream, Coder.Context context
       BoundedWindow window = windowCoder.decode(inStream);
       PaneInfo paneInfo = PaneInfo.PaneInfoCoder.INSTANCE.decode(inStream);
       CausedByDrain causedByDrain = CausedByDrain.NORMAL;
-      io.opentelemetry.context. @Nullable Context openTelemetryContext = null;
+      io.opentelemetry.context.@Nullable Context openTelemetryContext = null;
       if (WindowedValues.WindowedValueCoder.isMetadataSupported() && paneInfo.isElementMetadata()) {
         BeamFnApi.Elements.ElementMetadata elementMetadata =
             BeamFnApi.Elements.ElementMetadata.parseFrom(ByteArrayCoder.of().decode(inStream));
@@ -166,7 +174,8 @@ public ValueInSingleWindow<T> decode(InputStream inStream, Coder.Context context
 
       T value = valueCoder.decode(inStream, context);
       // todo #33176 specify additional metadata in the future
-      return new AutoValue_ValueInSingleWindow<>(value, timestamp, window, paneInfo, null, causedByDrain, openTelemetryContext);
+      return new AutoValue_ValueInSingleWindow<>(
+          value, timestamp, window, paneInfo, null, null, causedByDrain, openTelemetryContext);
     }
 
     @Override

sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowedValues.java

@@ -339,7 +339,7 @@ public static <T> WindowedValue<T> of(
       T value, Instant timestamp, BoundedWindow window, PaneInfo paneInfo) {
     checkArgument(paneInfo != null, "WindowedValue requires PaneInfo, but it was null");
 
-    return of(value, timestamp, window, paneInfo, CausedByDrain.NORMAL, null);
+    return of(value, timestamp, window, paneInfo, null, null, CausedByDrain.NORMAL, null);
   }
 
   /** Returns a {@code WindowedValue} with the given value, timestamp, and window. */
@@ -384,7 +384,8 @@ public static <T> WindowedValue<T> of(
    * default timestamp and pane.
    */
   public static <T> WindowedValue<T> valueInGlobalWindow(T value) {
-    return new ValueInGlobalWindow<>(value, PaneInfo.NO_FIRING, null, null, CausedByDrain.NORMAL, null);
+    return new ValueInGlobalWindow<>(
+        value, PaneInfo.NO_FIRING, null, null, CausedByDrain.NORMAL, null);
   }
 
   /**

sdks/java/core/src/test/java/org/apache/beam/sdk/util/WindowedValueTest.java

@@ -109,7 +109,8 @@ public void testWindowedValueWithElementMetadataCoder() throws CoderException {
             PaneInfo.NO_FIRING,
             null,
             null,
-            CausedByDrain.CAUSED_BY_DRAIN, context); // drain is persisted as part of metadata
+            CausedByDrain.CAUSED_BY_DRAIN,
+            context); // drain is persisted as part of metadata
 
     Coder<WindowedValue<String>> windowedValueCoder =
         WindowedValues.getFullCoder(StringUtf8Coder.of(), IntervalWindow.getCoder());