apache_beam.runners.direct.clock module

Clock implementations for real time processing and testing.

For internal use only. No backwards compatibility guarantees.

class apache_beam.runners.direct.clock.Clock

Bases: future.types.newobject.newobject

time()

Returns the number of seconds since epoch.

advance_time(advance_by)

Advances the clock by a number of seconds.

class apache_beam.runners.direct.clock.RealClock

Bases: future.types.newobject.newobject

time()

class apache_beam.runners.direct.clock.TestClock(current_time=0)

Bases: future.types.newobject.newobject

Clock used for Testing

time()

advance_time(advance_by)