org.apache.spark.streaming.util

Class ManualClock

Object

org.apache.spark.streaming.util.ManualClock

All Implemented Interfaces:

Clock

public class ManualClock
extends Object
implements Clock

Constructor Summary

Constructors

Constructor and Description
ManualClock()

Method Summary

Methods

Modifier and Type	Method and Description
void	addToTime(long timeToAdd)
long	currentTime()
void	setTime(long timeToSet)
long	time()
long	waitTillTime(long targetTime)

Methods inherited from class Object

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

Constructor Detail

ManualClock

public ManualClock()

Method Detail

time

public long time()

currentTime

public long currentTime()

Specified by:

currentTime in interface Clock

setTime

public void setTime(long timeToSet)

addToTime

public void addToTime(long timeToAdd)

waitTillTime

public long waitTillTime(long targetTime)

Specified by:

waitTillTime in interface Clock