Package org.apache.beam.sdk.transforms

Class DoFn.StartBundleContext

java.lang.Object

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

Enclosing class:

DoFn<InputT extends @Nullable Object,OutputT extends @Nullable Object>

public abstract class DoFn.StartBundleContext
extends Object

Information accessible while within the DoFn.StartBundle method.

Constructor Summary

Constructors

Constructor	Description
StartBundleContext()

Method Summary

Modifier and Type	Method	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 Details

StartBundleContext

public StartBundleContext()

Method Details

getPipelineOptions

@Pure
public abstract PipelineOptions getPipelineOptions()

Returns the PipelineOptions specified with the PipelineRunner invoking this DoFn.