0001
0002
0003
0004
0005
0006
0007
0008
0009
0010
0011
0012
0013
0014
0015
0016
0017
0018
0019 package org.apache.spark.streaming;
0020
0021 import org.apache.spark.streaming.api.java.*;
0022
0023 public class JavaStreamingListenerAPISuite extends JavaStreamingListener {
0024
0025 @Override
0026 public void onStreamingStarted(JavaStreamingListenerStreamingStarted streamingStarted) {
0027 super.onStreamingStarted(streamingStarted);
0028 }
0029
0030 @Override
0031 public void onReceiverStarted(JavaStreamingListenerReceiverStarted receiverStarted) {
0032 JavaReceiverInfo receiverInfo = receiverStarted.receiverInfo();
0033 receiverInfo.streamId();
0034 receiverInfo.name();
0035 receiverInfo.active();
0036 receiverInfo.location();
0037 receiverInfo.executorId();
0038 receiverInfo.lastErrorMessage();
0039 receiverInfo.lastError();
0040 receiverInfo.lastErrorTime();
0041 }
0042
0043 @Override
0044 public void onReceiverError(JavaStreamingListenerReceiverError receiverError) {
0045 JavaReceiverInfo receiverInfo = receiverError.receiverInfo();
0046 receiverInfo.streamId();
0047 receiverInfo.name();
0048 receiverInfo.active();
0049 receiverInfo.location();
0050 receiverInfo.executorId();
0051 receiverInfo.lastErrorMessage();
0052 receiverInfo.lastError();
0053 receiverInfo.lastErrorTime();
0054 }
0055
0056 @Override
0057 public void onReceiverStopped(JavaStreamingListenerReceiverStopped receiverStopped) {
0058 JavaReceiverInfo receiverInfo = receiverStopped.receiverInfo();
0059 receiverInfo.streamId();
0060 receiverInfo.name();
0061 receiverInfo.active();
0062 receiverInfo.location();
0063 receiverInfo.executorId();
0064 receiverInfo.lastErrorMessage();
0065 receiverInfo.lastError();
0066 receiverInfo.lastErrorTime();
0067 }
0068
0069 @Override
0070 public void onBatchSubmitted(JavaStreamingListenerBatchSubmitted batchSubmitted) {
0071 super.onBatchSubmitted(batchSubmitted);
0072 }
0073
0074 @Override
0075 public void onBatchStarted(JavaStreamingListenerBatchStarted batchStarted) {
0076 super.onBatchStarted(batchStarted);
0077 }
0078
0079 @Override
0080 public void onBatchCompleted(JavaStreamingListenerBatchCompleted batchCompleted) {
0081 super.onBatchCompleted(batchCompleted);
0082 }
0083
0084 @Override
0085 public void onOutputOperationStarted(
0086 JavaStreamingListenerOutputOperationStarted outputOperationStarted) {
0087 super.onOutputOperationStarted(outputOperationStarted);
0088 }
0089
0090 @Override
0091 public void onOutputOperationCompleted(
0092 JavaStreamingListenerOutputOperationCompleted outputOperationCompleted) {
0093 super.onOutputOperationCompleted(outputOperationCompleted);
0094 }
0095 }