You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by re...@apache.org on 2020/01/08 03:52:27 UTC
[beam] branch master updated (784d18b -> 4fc924a)
This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 784d18b [BEAM-8932] [BEAM-9036] Revert reverted commit to use PubsubMessage as the canonical type in beam client (#10474)
add 15a7ef1 onTimer/setTimer signature updates
add 4fc924a Merge pull request #10506: [BEAM-6857] OnTimer/SetTimer Signature Updates
No new revisions were added by this update.
Summary of changes:
.../translation/operators/ApexParDoOperator.java | 7 +++++-
.../org/apache/beam/runners/core/DoFnRunner.java | 8 ++++++-
.../runners/core/LateDataDroppingDoFnRunner.java | 9 ++++++--
.../apache/beam/runners/core/ProcessFnRunner.java | 7 +++++-
.../runners/core/PushbackSideInputDoFnRunner.java | 8 ++++++-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 7 +++++-
.../core/SimplePushbackSideInputDoFnRunner.java | 9 ++++++--
.../beam/runners/core/StatefulDoFnRunner.java | 9 ++++++--
.../beam/runners/core/SimpleDoFnRunnerTest.java | 11 +++++++++-
.../SimplePushbackSideInputDoFnRunnerTest.java | 25 +++++++++++++++++++---
.../beam/runners/core/StatefulDoFnRunnerTest.java | 8 ++++++-
.../apache/beam/runners/direct/ParDoEvaluator.java | 8 ++++++-
.../flink/metrics/DoFnRunnerWithMetricsUpdate.java | 4 +++-
.../functions/FlinkStatefulDoFnFunction.java | 8 ++++++-
.../wrappers/streaming/DoFnOperator.java | 7 +++++-
.../streaming/ExecutableStageDoFnOperator.java | 7 +++++-
.../streaming/stableinput/BufferedElements.java | 18 ++++++++++++++--
.../streaming/stableinput/BufferingDoFnRunner.java | 10 +++++++--
.../stableinput/BufferedElementsTest.java | 7 +++++-
.../dataflow/worker/DataflowProcessFnRunner.java | 7 +++++-
.../dataflow/worker/GroupAlsoByWindowFnRunner.java | 7 +++++-
.../runners/dataflow/worker/SimpleParDoFn.java | 8 ++++++-
.../StreamingKeyedWorkItemSideInputDoFnRunner.java | 7 +++++-
.../worker/StreamingSideInputDoFnRunner.java | 7 +++++-
.../runners/jet/processors/StatefulParDoP.java | 8 ++++++-
.../samza/metrics/DoFnRunnerWithMetrics.java | 12 +++++++++--
.../apache/beam/runners/samza/runtime/DoFnOp.java | 8 ++++++-
.../runtime/DoFnRunnerWithKeyedInternals.java | 17 ++++++++++++---
.../runners/samza/runtime/SamzaDoFnRunners.java | 7 +++++-
.../translation/batch/DoFnRunnerWithMetrics.java | 4 +++-
.../spark/translation/DoFnRunnerWithMetrics.java | 4 +++-
.../spark/translation/SparkProcessContext.java | 8 ++++++-
32 files changed, 239 insertions(+), 42 deletions(-)