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
