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=0)[source]
Bases: object
Clock used for Testing
-
time()[source]
-
advance_time(advance_by)[source]