@Internal public interface OnWatermarkCallback<KEY>
InternalWatermarkCallbackService
service. This callback will
be invoked for all keys registered with the service, upon reception of a watermark.Modifier and Type | Method and Description |
---|---|
void |
onWatermark(KEY key,
Watermark watermark)
The action to be triggered upon reception of a watermark.
|
void onWatermark(KEY key, Watermark watermark) throws IOException
key
- The current key.watermark
- The current watermark.IOException
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.