This change adds the reference DirectRunner implementation of the Python User State and Timers API. With this change, a user can execute DoFns with state and timers on the DirectRunner.
More details on the API design is available at https://s.apache.org/beam-python-user-state-and-timers. R: @robertwb CC: @lukecwik @tweise @aaltay [ Full content available at: https://github.com/apache/beam/pull/6304 ] This message was relayed via gitbox.apache.org for [email protected]
