public static class AggregatorsAccumulator.AccumulatorCheckpointingSparkListener
extends org.apache.spark.streaming.api.java.JavaStreamingListener
NamedAggregators
values for fault-tolerance.Constructor and Description |
---|
AccumulatorCheckpointingSparkListener() |
Modifier and Type | Method and Description |
---|---|
void |
onBatchCompleted(org.apache.spark.streaming.api.java.JavaStreamingListenerBatchCompleted batchCompleted) |