Package org.apache.beam.sdk.options
Class PipelineOptions.DirectRunner
- java.lang.Object
-
- org.apache.beam.sdk.options.PipelineOptions.DirectRunner
-
- All Implemented Interfaces:
DefaultValueFactory<java.lang.Class<? extends PipelineRunner<?>>>
- Enclosing interface:
- PipelineOptions
public static class PipelineOptions.DirectRunner extends java.lang.Object implements DefaultValueFactory<java.lang.Class<? extends PipelineRunner<?>>>
ADefaultValueFactory
that obtains the class of theDirectRunner
if it exists on the classpath, and throws an exception otherwise.As the
DirectRunner
is in an independent module, it cannot be directly referenced as theDefault
. However, it should still be used if available, and a user is required to explicitly set the--runner
property if they wish to use an alternative runner.
-
-
Constructor Summary
Constructors Constructor Description DirectRunner()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Class<? extends PipelineRunner<?>>
create(PipelineOptions options)
Creates a default value for a getter marked withDefault.InstanceFactory
.
-
-
-
Method Detail
-
create
public java.lang.Class<? extends PipelineRunner<?>> create(PipelineOptions options)
Description copied from interface:DefaultValueFactory
Creates a default value for a getter marked withDefault.InstanceFactory
.- Specified by:
create
in interfaceDefaultValueFactory<java.lang.Class<? extends PipelineRunner<?>>>
- Parameters:
options
- The current pipeline options.- Returns:
- The default value to be used for the annotated getter.
-
-