public static class DataflowPipelineDebugOptions.StagerFactory extends java.lang.Object implements DefaultValueFactory<Stager>
Stager
object using the class specified in DataflowPipelineDebugOptions.getStagerClass()
.Constructor and Description |
---|
StagerFactory() |
Modifier and Type | Method and Description |
---|---|
Stager |
create(PipelineOptions options)
Creates a default value for a getter marked with
Default.InstanceFactory . |
public Stager create(PipelineOptions options)
DefaultValueFactory
Default.InstanceFactory
.create
in interface DefaultValueFactory<Stager>
options
- The current pipeline options.