We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f7c280c commit bb06d9bCopy full SHA for bb06d9b
1 file changed
sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ViewTest.java
@@ -285,6 +285,7 @@ public void testTriggeredLatestSingleton() {
285
Window.<Long>into(FixedWindows.of(Duration.standardSeconds(1)))
286
.triggering(Repeatedly.forever(AfterProcessingTime.pastFirstElementInPane()))
287
.withAllowedLateness(Duration.ZERO)
288
+ .withOnTimeBehavior(Window.OnTimeBehavior.FIRE_IF_NON_EMPTY)
289
.discardingFiredPanes())
290
.apply(Reify.timestamps())
291
.apply(Combine.globally(Latest.<Long>combineFn()).withoutDefaults().asSingletonView());
0 commit comments