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

Fields

Modifier and Type	Field	Description
static final String	PROPERTY

Constructor Summary

Constructors

Constructor	Description
RegistryPipelineWorkerInitializer()

Method Summary

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

Field Details

PROPERTY

public static final String PROPERTY

See Also:

• Constant Field Values

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