public class OperatorEpochWatermarkTracker extends Object
Modifier and Type | Method and Description |
---|---|
void |
finish(int inputIndex) |
void |
onEpochWatermark(int inputIndex,
String sender,
int epochWatermark) |
public void onEpochWatermark(int inputIndex, String sender, int epochWatermark) throws IOException
IOException
public void finish(int inputIndex) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.