org.apache.flink.util.clock

Class ManualClock

java.lang.Object

org.apache.flink.util.clock.Clock

org.apache.flink.util.clock.ManualClock

@PublicEvolving
public final class ManualClock
extends Clock

A Clock implementation which allows to advance time manually.

Constructor Summary

Constructors

Constructor and Description
ManualClock()
ManualClock(long startTime)

Method Summary

Modifier and Type	Method and Description
long	absoluteTimeMillis() Gets the current absolute time, in milliseconds.
void	advanceTime(java.time.Duration duration) Advances the time by the given duration.
void	advanceTime(long duration, TimeUnit timeUnit) Advances the time by the given duration.
long	relativeTimeMillis() Gets the current relative time, in milliseconds.
long	relativeTimeNanos() Gets the current relative time, in nanoseconds.

Methods inherited from class java.lang.Object

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

Constructor Detail

ManualClock

public ManualClock()

ManualClock

public ManualClock(long startTime)

Method Detail

absoluteTimeMillis

public long absoluteTimeMillis()

Description copied from class: Clock

Gets the current absolute time, in milliseconds.

Specified by:

absoluteTimeMillis in class Clock

relativeTimeMillis

public long relativeTimeMillis()

Description copied from class: Clock

Gets the current relative time, in milliseconds.

Specified by:

relativeTimeMillis in class Clock

relativeTimeNanos

public long relativeTimeNanos()

Description copied from class: Clock

Gets the current relative time, in nanoseconds.

Specified by:

relativeTimeNanos in class Clock

advanceTime

public void advanceTime(long duration,
                        TimeUnit timeUnit)

Advances the time by the given duration. Time can also move backwards by supplying a negative value. This method performs no overflow check.

advanceTime

public void advanceTime(java.time.Duration duration)

Advances the time by the given duration. Time can also move backwards by supplying a negative value. This method performs no overflow check.