org.apache.beam.sdk.options

Interface DefaultValueFactory<T>

Type Parameters:

T - The type of object this factory produces.

All Known Implementing Classes:

DataflowPipelineDebugOptions.DataflowClientFactory, DataflowPipelineDebugOptions.StagerFactory, DataflowPipelineOptions.StagingLocationFactory, DataflowPipelineWorkerPoolOptions.WorkerHarnessContainerImageFactory, DefaultParallelismFactory, DirectOptions.AvailableParallelismFactory, GcpOptions.DefaultProjectFactory, GcpOptions.GcpTempLocationFactory, GcpOptions.GcpUserCredentialsFactory, GcsOptions.ExecutorServiceFactory, GcsOptions.PathValidatorFactory, HadoopFileSystemOptions.ConfigurationLocator, PipelineOptions.AtomicLongFactory, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, SparkContextOptions.EmptyListenersList, SparkPipelineOptions.TmpCheckpointDirFactory, TestPipelineOptions.AlwaysPassMatcherFactory, TestSparkPipelineOptions.DefaultStopPipelineWatermarkFactory

public interface DefaultValueFactory<T>

An interface used with the Default.InstanceFactory annotation to specify the class that will be an instance factory to produce default values for a given getter on PipelineOptions. When a property on a PipelineOptions is fetched, and is currently unset, the default value factory will be instantiated and invoked.

Care must be taken to not produce an infinite loop when accessing other fields on the PipelineOptions object.

Method Summary

Modifier and Type	Method and Description
T	create(PipelineOptions options) Creates a default value for a getter marked with Default.InstanceFactory.

Method Detail

create

T create(PipelineOptions options)

Creates a default value for a getter marked with Default.InstanceFactory.

Parameters:

options - The current pipeline options.

Returns:

The default value to be used for the annotated getter.