org.apache.spark.util

Class ManualClock

Object

org.apache.spark.util.ManualClock

All Implemented Interfaces:

Clock

public class ManualClock
extends Object
implements Clock

A Clock whose time can be manually set and modified. Its reported time does not change as time elapses, but only as its time is modified by callers. This is mainly useful for testing.

Constructor Summary

Constructors

Constructor and Description
ManualClock()
ManualClock(long time)

Method Summary

Methods

Modifier and Type	Method and Description
void	advance(long timeToAdd)
long	getTimeMillis()
void	setTime(long timeToSet)
long	waitTillTime(long targetTime)

Methods inherited from class Object

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

Constructor Detail

ManualClock

public ManualClock(long time)

ManualClock

public ManualClock()

Method Detail

getTimeMillis

public long getTimeMillis()

Specified by:

getTimeMillis in interface Clock

setTime

public void setTime(long timeToSet)

Parameters:

timeToSet - new time (in milliseconds) that the clock should represent

advance

public void advance(long timeToAdd)

Parameters:

timeToAdd - time (in milliseconds) to add to the clock's time

waitTillTime

public long waitTillTime(long targetTime)

Specified by:

waitTillTime in interface Clock

Parameters:

targetTime - block until the clock time is set or advanced to at least this time

Returns:

current time reported by the clock when waiting finishes