org.apache.beam.sdk.transforms

Class DoFn.StartBundleContext

java.lang.Object

org.apache.beam.sdk.transforms.DoFn.StartBundleContext

Enclosing class:

DoFn<InputT,OutputT>

public abstract class DoFn.StartBundleContext
extends java.lang.Object

Information accessible while within the DoFn.StartBundle method.

Constructor Summary

Constructors

Constructor and Description
StartBundleContext()

Method Summary

Modifier and Type	Method and Description
abstract PipelineOptions	getPipelineOptions() Returns the PipelineOptions specified with the PipelineRunner invoking this DoFn.

Methods inherited from class java.lang.Object

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

Constructor Detail

StartBundleContext

public StartBundleContext()

Method Detail

getPipelineOptions

public abstract PipelineOptions getPipelineOptions()

Returns the PipelineOptions specified with the PipelineRunner invoking this DoFn. The PipelineOptions will be the default running via DoFnTester.