org.apache.spark.streaming

Class ContextWaiter

Object

org.apache.spark.streaming.ContextWaiter

public class ContextWaiter
extends Object

Constructor Summary

Constructors

Constructor and Description
ContextWaiter()

Method Summary

Methods

Modifier and Type	Method and Description
void	notifyError(Throwable e)
void	notifyStop()
boolean	waitForStopOrError(long timeout) Return true if it's stopped; or throw the reported error if notifyError has been called; or false if the waiting time detectably elapsed before return from the method.

Methods inherited from class Object

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

Constructor Detail

ContextWaiter

public ContextWaiter()

Method Detail

notifyError

public void notifyError(Throwable e)

notifyStop

public void notifyStop()

waitForStopOrError

public boolean waitForStopOrError(long timeout)

Return true if it's stopped; or throw the reported error if notifyError has been called; or false if the waiting time detectably elapsed before return from the method.