org.apache.spark.streaming.scheduler

Class DeregisterReceiver

Object

org.apache.spark.streaming.scheduler.DeregisterReceiver

All Implemented Interfaces:

java.io.Serializable, ReceiverTrackerMessage, scala.Equals, scala.Product

public class DeregisterReceiver
extends Object
implements ReceiverTrackerMessage, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DeregisterReceiver(int streamId, String msg, String error)

Method Summary

Methods

Modifier and Type	Method and Description
String	error()
String	msg()
int	streamId()

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

Constructor Detail

DeregisterReceiver

public DeregisterReceiver(int streamId,
                  String msg,
                  String error)

Method Detail

streamId

public int streamId()

msg

public String msg()

error

public String error()