org.apache.spark.streaming.scheduler

Class RegisterReceiver

Object

org.apache.spark.streaming.scheduler.RegisterReceiver

All Implemented Interfaces:

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

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RegisterReceiver(int streamId, String typ, String host, akka.actor.ActorRef receiverActor)

Method Summary

Methods

Modifier and Type	Method and Description
String	host()
akka.actor.ActorRef	receiverActor()
int	streamId()
String	typ()

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

RegisterReceiver

public RegisterReceiver(int streamId,
                String typ,
                String host,
                akka.actor.ActorRef receiverActor)

Method Detail

streamId

public int streamId()

typ

public String typ()

host

public String host()

receiverActor

public akka.actor.ActorRef receiverActor()