org.apache.spark.streaming.util

Class SystemClock

Object

org.apache.spark.streaming.util.SystemClock

All Implemented Interfaces:

Clock

public class SystemClock
extends Object
implements Clock

Constructor Summary

Constructors

Constructor and Description
SystemClock()

Method Summary

Methods

Modifier and Type	Method and Description
long	currentTime()
long	minPollTime()
long	waitTillTime(long targetTime)

Methods inherited from class Object

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

Constructor Detail

SystemClock

public SystemClock()

Method Detail

minPollTime

public long minPollTime()

currentTime

public long currentTime()

Specified by:

currentTime in interface Clock

waitTillTime

public long waitTillTime(long targetTime)

Specified by:

waitTillTime in interface Clock