diff options
Diffstat (limited to 'streaming/src/main/scala/org/apache/spark/streaming/scheduler/StreamingListener.scala')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/scheduler/StreamingListener.scala | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/StreamingListener.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/StreamingListener.scala index 58fc78d552..b57f9b772f 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/StreamingListener.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/StreamingListener.scala @@ -30,6 +30,9 @@ import org.apache.spark.util.Distribution sealed trait StreamingListenerEvent @DeveloperApi +case class StreamingListenerStreamingStarted(time: Long) extends StreamingListenerEvent + +@DeveloperApi case class StreamingListenerBatchSubmitted(batchInfo: BatchInfo) extends StreamingListenerEvent @DeveloperApi @@ -66,6 +69,9 @@ case class StreamingListenerReceiverStopped(receiverInfo: ReceiverInfo) @DeveloperApi trait StreamingListener { + /** Called when the streaming has been started */ + def onStreamingStarted(streamingStarted: StreamingListenerStreamingStarted) { } + /** Called when a receiver has been started */ def onReceiverStarted(receiverStarted: StreamingListenerReceiverStarted) { } |