[beam] branch master updated (088d16c -> 2638883)

[lc...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 088d16c  Merge pull request #8627 from tvalentyn/patch-51
     add 2638883  [BEAM-6872] Add hook for user-defined JVM initialization in workers (#8104)

No new revisions were added by this update.

Summary of changes:
 .../worker/DataflowBatchWorkerHarness.java         |  5 ++
 .../dataflow/worker/StreamingDataflowWorker.java   |  4 ++
 .../apache/beam/sdk/harness/JvmInitializer.java    | 56 ++++++++++++++++
 .../org/apache/beam/sdk/harness}/package-info.java |  4 +-
 .../beam/sdk/options/PipelineOptionsFactory.java   | 17 ++---
 .../beam/sdk/util/common/ReflectHelpers.java       | 31 ++++++++-
 .../beam/sdk/util/common/ReflectHelpersTest.java   | 41 ++++++++++++
 ....sdk.util.common.ReflectHelpersTest$FakeService | 13 +---
 .../org/apache/beam/sdk/fn/JvmInitializers.java    | 49 ++++++++++++++
 .../apache/beam/sdk/fn/JvmInitializersTest.java    | 78 ++++++++++++++++++++++
 .../java/org/apache/beam/fn/harness/FnHarness.java | 56 +++++++++++++---
 .../org/apache/beam/fn/harness/FnHarnessTest.java  | 61 +++++++++++++++--
 12 files changed, 374 insertions(+), 41 deletions(-)
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/harness/JvmInitializer.java
 copy {runners/core-java/src/main/java/org/apache/beam/runners/core => sdks/java/core/src/main/java/org/apache/beam/sdk/harness}/package-info.java (91%)
 copy .test-infra/kubernetes/elasticsearch/data-load-setup.sh => sdks/java/core/src/test/resources/META-INF/services/org.apache.beam.sdk.util.common.ReflectHelpersTest$FakeService (79%)
 create mode 100644 sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/JvmInitializers.java
 create mode 100644 sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/JvmInitializersTest.java