public interface OperatorEpochWatermarkTrackerListener
Modifier and Type | Method and Description |
---|---|
void |
onEpochWatermarkIncrement(int epochWatermark)
Notifies a new round is aligned to a new epoch watermark.
|
void onEpochWatermarkIncrement(int epochWatermark) throws IOException
epochWatermark
- The new epoch watermark.IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.