Package org.apache.beam.sdk.options
Interface PipelineOptionsRegistrar
- All Known Implementing Classes:
AwsPipelineOptionsRegistrar
,AzurePipelineOptionsRegistrar
,BeamSqlPipelineOptionsRegistrar
,DataCatalogPipelineOptionsRegistrar
,DataflowPipelineRegistrar.Options
,DefaultPipelineOptionsRegistrar
,DirectRegistrar.Options
,FlinkRunnerRegistrar.Options
,GcpIoPipelineOptionsRegistrar
,GcpPipelineOptionsRegistrar
,HadoopFileSystemOptionsRegistrar
,JetRunnerRegistrar.Options
,KinesisIOOptions.KinesisIOOptionsRegistrar
,ManualDockerEnvironmentOptions.Options
,PrismRegistrar.Options
,PythonExternalTransformOptionsRegistrar
,RemoteEnvironmentOptions.Options
,ResourceHintsOptions.Options
,SparkRunnerRegistrar.Options
,SparkStructuredStreamingRunnerRegistrar.Options
,TestPortablePipelineOptions.TestPortablePipelineOptionsRegistrar
,TestUniversalRunner.OptionsRegistrar
,Twister2RunnerRegistrar.Options
public interface PipelineOptionsRegistrar
PipelineOptions
creators have the ability to automatically have their PipelineOptions
registered with this SDK by creating a ServiceLoader
entry and a
concrete implementation of this interface.
Note that automatic registration of any PipelineOptions
requires users conform to the
limitations discussed on PipelineOptionsFactory.register(Class)
.
It is optional but recommended to use one of the many build time tools such as AutoService
to generate the necessary META-INF files automatically.
-
Method Summary
-
Method Details
-
getPipelineOptions
Iterable<Class<? extends PipelineOptions>> getPipelineOptions()
-