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 84c12eb [BEAM-9383] Staging Dataflow artifacts from environment
(#11039)
add 03d99df [BEAM-1589] Added @OnWindowExpiration annotation. (#11350)
No new revisions were added by this update.
Summary of changes:
runners/apex/build.gradle | 1 +
.../org/apache/beam/runners/core/DoFnRunner.java | 6 +
.../runners/core/LateDataDroppingDoFnRunner.java | 5 +
.../beam/runners/core/ReduceFnContextFactory.java | 5 +
.../apache/beam/runners/core/SimpleDoFnRunner.java | 210 +++++++++++++++++++++
.../beam/runners/core/StatefulDoFnRunner.java | 9 +-
.../TriggerStateMachineContextFactory.java | 5 +
.../SimplePushbackSideInputDoFnRunnerTest.java | 3 +
.../core/triggers/TriggerStateMachineTester.java | 5 +
runners/flink/flink_runner.gradle | 1 +
runners/flink/job-server/flink_job_server.gradle | 1 +
.../flink/metrics/DoFnRunnerWithMetricsUpdate.java | 5 +
.../streaming/ExecutableStageDoFnOperator.java | 3 +
.../streaming/stableinput/BufferingDoFnRunner.java | 3 +
runners/gearpump/build.gradle | 1 +
.../dataflow/worker/BatchModeExecutionContext.java | 48 +++--
.../dataflow/worker/DataflowExecutionContext.java | 6 +-
.../dataflow/worker/DataflowProcessFnRunner.java | 5 +
.../dataflow/worker/GroupAlsoByWindowFnRunner.java | 3 +
.../runners/dataflow/worker/SimpleParDoFn.java | 13 +-
.../StreamingKeyedWorkItemSideInputDoFnRunner.java | 5 +
.../worker/StreamingModeExecutionContext.java | 22 ++-
.../worker/StreamingSideInputDoFnRunner.java | 5 +
.../dataflow/worker/WindmillTimerInternals.java | 15 +-
.../dataflow/worker/UserParDoFnFactoryTest.java | 2 +
.../fn/control/BeamFnMapTaskExecutorTest.java | 6 +-
runners/jet/build.gradle | 1 +
runners/samza/build.gradle | 1 +
.../samza/metrics/DoFnRunnerWithMetrics.java | 5 +
.../runtime/DoFnRunnerWithKeyedInternals.java | 5 +
.../runners/samza/runtime/SamzaDoFnRunners.java | 3 +
runners/spark/build.gradle | 2 +
runners/spark/job-server/build.gradle | 1 +
.../translation/batch/DoFnRunnerWithMetrics.java | 5 +
.../spark/translation/DoFnRunnerWithMetrics.java | 5 +
.../java/org/apache/beam/sdk/state/Timers.java | 3 +
...temMetrics.java => UsesOnWindowExpiration.java} | 6 +-
.../java/org/apache/beam/sdk/transforms/DoFn.java | 6 +
.../beam/sdk/transforms/reflect/DoFnSignature.java | 17 ++
.../sdk/transforms/reflect/DoFnSignatures.java | 25 ++-
.../org/apache/beam/sdk/transforms/ParDoTest.java | 95 ++++++++++
41 files changed, 542 insertions(+), 31 deletions(-)
copy
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/{UsesSystemMetrics.java
=> UsesOnWindowExpiration.java} (84%)
