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[source]¶

Bases: object

time()[source]¶: Returns the number of seconds since epoch.

advance_time(advance_by)[source]¶: Advances the clock by a number of seconds.

class apache_beam.runners.direct.clock.RealClock[source]¶

Bases: object

time()[source]¶

class apache_beam.runners.direct.clock.TestClock(current_time=None)[source]¶

Bases: object

Clock used for Testing

time()[source]¶

advance_time(advance_by)[source]¶