Class ReceiverInfo

Object
org.apache.spark.status.api.v1.streaming.ReceiverInfo

public class ReceiverInfo extends Object
  • 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()
    • streamName

      public String streamName()