This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 4b7b746 Merge pull request #14540: Remove uses of
WindowFn.getOutputTime
add d57dee1 [BEAM-11914] Add PipelineOptions as DoFn @Setup parameters
(#14155)
No new revisions were added by this update.
Summary of changes:
.../runners/core/construction/SplittableParDo.java | 10 ++---
.../construction/SplittableParDoNaiveBounded.java | 16 ++++++--
.../core/SplittableParDoViaKeyedWorkItems.java | 19 +++++++++-
.../beam/runners/direct/DoFnLifecycleManager.java | 15 +++++---
.../beam/runners/direct/ParDoEvaluatorFactory.java | 3 +-
.../SplittableProcessElementsEvaluatorFactory.java | 2 +-
.../direct/StatefulParDoEvaluatorFactory.java | 2 +-
...cycleManagerRemovingTransformEvaluatorTest.java | 3 +-
.../runners/direct/DoFnLifecycleManagerTest.java | 3 +-
.../runners/direct/DoFnLifecycleManagersTest.java | 16 +++++---
.../translation/functions/FlinkDoFnFunction.java | 7 ++--
.../functions/FlinkStatefulDoFnFunction.java | 5 ++-
.../wrappers/streaming/DoFnOperator.java | 4 +-
.../dataflow/BatchStatefulParDoOverrides.java | 5 ++-
.../dataflow/worker/DoFnInstanceManagers.java | 13 ++++---
.../dataflow/worker/UserParDoFnFactory.java | 3 +-
.../dataflow/worker/DoFnInstanceManagersTest.java | 9 +++--
.../runners/dataflow/worker/SimpleParDoFnTest.java | 4 +-
.../runners/jet/processors/AbstractParDoP.java | 3 +-
.../apache/beam/runners/samza/runtime/DoFnOp.java | 7 ++--
.../samza/runtime/SamzaDoFnInvokerRegistrar.java | 5 ++-
.../SplittableParDoProcessKeyedElementsOp.java | 2 +-
.../translation/batch/DoFnFunction.java | 2 +-
.../spark/translation/MultiDoFnFunction.java | 2 +-
.../translators/functions/DoFnFunction.java | 2 +-
.../org/apache/beam/sdk/transforms/DoFnTester.java | 14 ++++++-
.../reflect/ByteBuddyDoFnInvokerFactory.java | 4 +-
.../beam/sdk/transforms/reflect/DoFnInvoker.java | 2 +-
.../beam/sdk/transforms/reflect/DoFnInvokers.java | 27 ++++++++++++-
.../beam/sdk/transforms/reflect/DoFnSignature.java | 10 +++--
.../sdk/transforms/reflect/DoFnSignatures.java | 44 ++++++++++++++++++++--
.../org/apache/beam/sdk/transforms/ParDoTest.java | 29 ++++++++++++++
.../sdk/transforms/reflect/DoFnInvokersTest.java | 11 ++++--
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 3 +-
34 files changed, 228 insertions(+), 78 deletions(-)
