Package org.apache.beam.sdk.fn

Class JvmInitializers

java.lang.Object

org.apache.beam.sdk.fn.JvmInitializers

public class JvmInitializers
extends Object

Helpers for executing JvmInitializer implementations.

Constructor Summary

Constructors

Constructor	Description
JvmInitializers()

Method Summary

Modifier and Type	Method	Description
static void	runBeforeProcessing(PipelineOptions options)	Finds all registered implementations of JvmInitializer and executes their beforeProcessing methods.
static void	runOnStartup()	Finds all registered implementations of JvmInitializer and executes their onStartup methods.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JvmInitializers

public JvmInitializers()

Method Details

runOnStartup

public static void runOnStartup()

Finds all registered implementations of JvmInitializer and executes their onStartup methods. Should be called in worker harness implementations at the very beginning of their main method.

runBeforeProcessing

public static void runBeforeProcessing(PipelineOptions options)

Finds all registered implementations of JvmInitializer and executes their beforeProcessing methods. Should be called in worker harness implementations after initialization but before beginning to process any data.

Parameters:

options - The pipeline options passed to the worker.