Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractProcessor.keyedWatermarkCheck(Watermark watermark)
Throws
UnsupportedOperationException if watermark has non-zero
key. |
default boolean |
Processor.tryProcessWatermark(int ordinal,
Watermark watermark)
Tries to process the supplied watermark.
|
boolean |
Processor.tryProcessWatermark(Watermark watermark)
Tries to process the supplied watermark.
|
boolean |
AbstractProcessor.tryProcessWatermark(Watermark watermark)
This basic implementation only forwards the passed watermark.
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.