[beam] branch master updated (f5e69be -> bb76eed)

[re...@apache.org]

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 f5e69be  [BEAM-9124] Linkage Checker 1.1.2 to use Maven Central HTTPS URL (#10603)
     add bb76eed  Merge pull request #10316: [BEAM-6857] Support Dynamic Timers

No new revisions were added by this update.

Summary of changes:
 .../pipeline/src/main/proto/beam_runner_api.proto  |  21 ++
 .../translation/operators/ApexTimerInternals.java  |   2 +-
 .../operators/ApexTimerInternalsTest.java          |   2 +-
 .../core/construction/ParDoTranslation.java        |  31 ++-
 .../runners/core/construction/SplittableParDo.java |   8 +
 .../construction/SplittableParDoNaiveBounded.java  |  11 +
 .../beam/runners/core/InMemoryTimerInternals.java  |  24 +-
 ...TimeBoundedSplittableProcessElementInvoker.java |  13 +
 .../apache/beam/runners/core/SimpleDoFnRunner.java | 129 +++++++++-
 .../apache/beam/runners/core/TimerInternals.java   |  16 +-
 .../runners/core/InMemoryTimerInternalsTest.java   |  12 +-
 .../beam/runners/core/SimpleDoFnRunnerTest.java    |   4 +-
 .../SimplePushbackSideInputDoFnRunnerTest.java     |   7 +-
 .../beam/runners/direct/DirectTimerInternals.java  |   2 +-
 .../runners/direct/ParDoMultiOverrideFactory.java  |   3 +-
 .../direct/StatefulParDoEvaluatorFactory.java      |   3 +-
 .../beam/runners/direct/WatermarkManager.java      |  45 ++--
 runners/flink/flink_runner.gradle                  |   1 +
 .../wrappers/streaming/DoFnOperator.java           |   2 +-
 .../dataflow/PrimitiveParDoSingleFactory.java      |  16 ++
 .../dataflow/worker/WindmillTimerInternals.java    | 105 +++++++--
 .../beam/runners/samza/runtime/KeyedInternals.java |   4 +-
 .../samza/runtime/SamzaTimerInternalsFactory.java  |   2 +-
 .../spark/stateful/SparkTimerInternals.java        |   2 +-
 .../sdk/state/{package-info.java => TimerMap.java} |  15 +-
 .../java/org/apache/beam/sdk/state/TimerSpecs.java |   4 +
 .../{UsesSystemMetrics.java => UsesTimerMap.java}  |   7 +-
 .../java/org/apache/beam/sdk/transforms/DoFn.java  |  29 +++
 .../org/apache/beam/sdk/transforms/DoFnTester.java |  17 ++
 .../java/org/apache/beam/sdk/transforms/ParDo.java |  12 +
 .../reflect/ByteBuddyDoFnInvokerFactory.java       | 136 +++++++++--
 .../reflect/ByteBuddyOnTimerInvokerFactory.java    | 136 +++++++++++
 .../beam/sdk/transforms/reflect/DoFnInvoker.java   |  27 ++-
 .../beam/sdk/transforms/reflect/DoFnSignature.java | 113 ++++++++-
 .../sdk/transforms/reflect/DoFnSignatures.java     | 262 ++++++++++++++++++++-
 .../sdk/transforms/reflect/OnTimerInvokers.java    |   5 +
 .../org/apache/beam/sdk/transforms/ParDoTest.java  | 151 ++++++++++++
 .../sdk/transforms/reflect/DoFnInvokersTest.java   |   6 +-
 .../sdk/transforms/reflect/DoFnSignaturesTest.java |   5 +
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    |  38 ++-
 40 files changed, 1317 insertions(+), 111 deletions(-)
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/state/{package-info.java => TimerMap.java} (78%)
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/testing/{UsesSystemMetrics.java => UsesTimerMap.java} (82%)