Package google.registry.beam.common
Class RegistryPipelineWorkerInitializer
java.lang.Object
google.registry.beam.common.RegistryPipelineWorkerInitializer
- All Implemented Interfaces:
org.apache.beam.sdk.harness.JvmInitializer
@AutoService(org.apache.beam.sdk.harness.JvmInitializer.class)
public class RegistryPipelineWorkerInitializer
extends Object
implements org.apache.beam.sdk.harness.JvmInitializer
Sets up Nomulus environment and initializes JPA on each pipeline worker. It is assumed that the
pipeline only works with one SQL database.
This class only takes effect in portable beam pipeline runners (including the Cloud Dataflow runner). It is not invoked in test pipelines.
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
beforeProcessing
(org.apache.beam.sdk.options.PipelineOptions options) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.beam.sdk.harness.JvmInitializer
onStartup
-
Field Details
-
PROPERTY
- See Also:
-
-
Constructor Details
-
RegistryPipelineWorkerInitializer
public RegistryPipelineWorkerInitializer()
-
-
Method Details
-
beforeProcessing
public void beforeProcessing(org.apache.beam.sdk.options.PipelineOptions options) - Specified by:
beforeProcessing
in interfaceorg.apache.beam.sdk.harness.JvmInitializer
-