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 Details

  • Constructor Details

    • RegistryPipelineWorkerInitializer

      public RegistryPipelineWorkerInitializer()
  • Method Details

    • beforeProcessing

      public void beforeProcessing(org.apache.beam.sdk.options.PipelineOptions options)
      Specified by:
      beforeProcessing in interface org.apache.beam.sdk.harness.JvmInitializer