We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents b296b40 + bb06d9b commit 91e1b06Copy full SHA for 91e1b06
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