public interface BoundedChecker
Modifier and Type | Method and Description |
---|---|
static BoundedChecker |
neverEnd() |
boolean |
shouldEndInput(Snapshot snapshot) |
static BoundedChecker |
watermark(long boundedWatermark) |
boolean shouldEndInput(Snapshot snapshot)
static BoundedChecker neverEnd()
static BoundedChecker watermark(long boundedWatermark)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.