Skip to content

Commit 951943e

Browse files
committed
add draining to output builder
1 parent a6d2b7d commit 951943e

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

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

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,10 @@ public void testWindowedValueWithElementMetadataCoder() throws CoderException {
8989
new IntervalWindow(timestamp, timestamp.plus(Duration.millis(1000))),
9090
new IntervalWindow(
9191
timestamp.plus(Duration.millis(1000)), timestamp.plus(Duration.millis(2000)))),
92-
PaneInfo.NO_FIRING);
92+
PaneInfo.NO_FIRING,
93+
null,
94+
null,
95+
true);
9396

9497
Coder<WindowedValue<String>> windowedValueCoder =
9598
WindowedValues.getFullCoder(StringUtf8Coder.of(), IntervalWindow.getCoder());
@@ -101,6 +104,7 @@ public void testWindowedValueWithElementMetadataCoder() throws CoderException {
101104
Assert.assertEquals(value.getValue(), decodedValue.getValue());
102105
Assert.assertEquals(value.getTimestamp(), decodedValue.getTimestamp());
103106
Assert.assertArrayEquals(value.getWindows().toArray(), decodedValue.getWindows().toArray());
107+
Assert.assertTrue(value.isDraining());
104108
}
105109

106110
@Test

0 commit comments

Comments
 (0)