spotless

stankiewicz · stankiewicz · commit 89e0ba0e59f6 · 2026-03-12T16:14:46.000+01:00
diff --git a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java
@@ -1936,6 +1936,12 @@ public <T> void outputWindowedValue(
       }
       outputTo(consumer, WindowedValues.of(output, timestamp, windows, paneInfo));
     }
+
+    @Override
+    public CausedByDrain causedByDrain() {
+      return currentElement.causedByDrain();
+    }
+
     @Override
     public CausedByDrain causedByDrain(DoFn<InputT, OutputT> doFn) {
       return currentElement.causedByDrain();

Original file line number	Diff line number	Diff line change
`@@ -1936,6 +1936,12 @@ public <T> void outputWindowedValue(`
`1936`	`1936`	`}`
`1937`	`1937`	`outputTo(consumer, WindowedValues.of(output, timestamp, windows, paneInfo));`
`1938`	`1938`	`}`
	`1939`	`+`
	`1940`	`+ @Override`
	`1941`	`+ public CausedByDrain causedByDrain() {`
	`1942`	`+ return currentElement.causedByDrain();`
	`1943`	`+ }`
	`1944`	`+`
`1939`	`1945`	`@Override`
`1940`	`1946`	`public CausedByDrain causedByDrain(DoFn<InputT, OutputT> doFn) {`
`1941`	`1947`	`return currentElement.causedByDrain();`