Object
org.apache.spark.status.api.v1.streaming.ReceiverInfo
public class ReceiverInfo
extends Object
-
Method Summary
-
Method Details
-
avgEventRate
public scala.Option<Object> avgEventRate()
-
eventRates
public scala.collection.Seq<scala.Tuple2<Object,Object>> eventRates()
-
executorHost
public scala.Option<String> executorHost()
-
executorId
public scala.Option<String> executorId()
-
isActive
public scala.Option<Object> isActive()
-
lastError
public scala.Option<String> lastError()
-
lastErrorMessage
public scala.Option<String> lastErrorMessage()
-
lastErrorTime
public scala.Option<Date> lastErrorTime()
-
streamId
public int streamId()
-