This is an automated email from the ASF dual-hosted git repository.
jaku pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 182b5cf Merge pull request #7815 from ibzib/write-to-bq
new 9a1d91f Modify ValidatesRunner to only run a custom test interface
for user timers
new 19b78ab Fill in the ProcessBundleDescriptor with correct user timer
information
new ee115ca spotless
new cd1250e fix timers to have correct kv coder
new 679ccec Add timers to the ExecutionStage
new abf0aa4 add initial Dataflow portable user timer implementation
new 86e62ce inform the SDK harness of the timers
new 8cae9f2 spotless
new d61937e clean up comments
new 8b5f703 remove extra log lines
new a0417dd remote try-catch in receive
new 1e7a863 change todos to have jira
new 30f6ca4 Add user timer support in ParDoTest.java
new 7dcc315 spotless
new f2a0487 fix merge
new 95eaf7d remove dev files
new f2532f6 undo changes
new dc54c95 redundant logic
new 5341976 undo changes?
new 8b1b474 revert register node function (old unnecessary changes
new a4ebe32 changes
new de1fa39 bad
new 76d2fed move fire timers to receive
new b7fafe9 Update ParDoTest to add more supported timer tests to Dataflow
new 5886634 spotless apply
new a766166 clean up
new d691a49 finishing touches on user timers
new b05be3c remove logger
new ffd9026 remove timer align bounded as supported
new 177e955 remove force experiment
new a5c00e4 experimental flag isn't in yet, remove supoprt
new c5a19f4 Refactor timer implementation into its own class
new b7cbfa5 fix imports, and change string to byte encoder for timer test
new 3a55c05 Merge pull request #7330: [BEAM-6233]: Add initial user timer
support in Dataflow for batch pipelines
The 20112 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../google-cloud-dataflow-java/worker/build.gradle | 1 +
.../worker/BeamFnMapTaskExecutorFactory.java | 16 +-
.../fn/control/ProcessRemoteBundleOperation.java | 57 ++-
.../dataflow/worker/fn/control/TimerReceiver.java | 257 ++++++++++
.../graph/CreateExecutableStageNodeFunction.java | 30 +-
.../worker/fn/control/TimerReceiverTest.java | 524 +++++++++++++++++++++
6 files changed, 857 insertions(+), 28 deletions(-)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/TimerReceiver.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/fn/control/TimerReceiverTest.java
