org.apache.spark.streaming.scheduler

Class ReceiverTracker.ReceiverLauncher

Object

org.apache.spark.streaming.scheduler.ReceiverTracker.ReceiverLauncher

Enclosing class:

ReceiverTracker

public class ReceiverTracker.ReceiverLauncher
extends Object

This thread class runs all the receivers on the cluster.

Constructor Summary

Constructors

Constructor and Description
ReceiverTracker.ReceiverLauncher()

Method Summary

Methods

Modifier and Type	Method and Description
SparkEnv	env()
void	start()
void	stop(boolean graceful)
Thread	thread()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReceiverTracker.ReceiverLauncher

public ReceiverTracker.ReceiverLauncher()

Method Detail

env

public SparkEnv env()

thread

public Thread thread()

start

public void start()

stop

public void stop(boolean graceful)