org.apache.spark.streaming.scheduler
Class ReceiverInfo
Object
org.apache.spark.streaming.scheduler.ReceiverInfo
- All Implemented Interfaces:
- java.io.Serializable, scala.Equals, scala.Product
public class ReceiverInfo
- extends Object
- implements scala.Product, scala.Serializable
:: DeveloperApi ::
Class having information about a receiver
- See Also:
- Serialized Form
Constructor Summary |
ReceiverInfo(int streamId,
String name,
org.apache.spark.rpc.RpcEndpointRef endpoint,
boolean active,
String location,
String lastErrorMessage,
String lastError,
long lastErrorTime)
|
Methods inherited from class Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface scala.Product |
productArity, productElement, productIterator, productPrefix |
Methods inherited from interface scala.Equals |
canEqual, equals |
ReceiverInfo
public ReceiverInfo(int streamId,
String name,
org.apache.spark.rpc.RpcEndpointRef endpoint,
boolean active,
String location,
String lastErrorMessage,
String lastError,
long lastErrorTime)
streamId
public int streamId()
name
public String name()
endpoint
public org.apache.spark.rpc.RpcEndpointRef endpoint()
active
public boolean active()
location
public String location()
lastErrorMessage
public String lastErrorMessage()
lastError
public String lastError()
lastErrorTime
public long lastErrorTime()