public static class GlobalWatermarkHolder.WatermarksListener
extends org.apache.spark.streaming.api.java.JavaStreamingListener
Constructor and Description |
---|
WatermarksListener() |
Modifier and Type | Method and Description |
---|---|
void |
onBatchCompleted(org.apache.spark.streaming.api.java.JavaStreamingListenerBatchCompleted batchCompleted) |