Class RegistryPipelineWorkerInitializer

  • All Implemented Interfaces:
    org.apache.beam.sdk.harness.JvmInitializer

    @AutoService(org.apache.beam.sdk.harness.JvmInitializer.class)
    public class RegistryPipelineWorkerInitializer
    extends java.lang.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.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void 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
    • Constructor Detail

      • RegistryPipelineWorkerInitializer

        public RegistryPipelineWorkerInitializer()
    • Method Detail

      • beforeProcessing

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