Package org.apache.beam.sdk.transforms

Class DoFn.ProcessContext

java.lang.Object

DoFn<InputT,OutputT>.org.apache.beam.sdk.transforms.DoFn.WindowedContext

org.apache.beam.sdk.transforms.DoFn.ProcessContext

Enclosing class:

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

public abstract class DoFn.ProcessContext
extends DoFn<InputT,OutputT>.WindowedContext

Information accessible when running a DoFn.ProcessElement method.

Constructor Summary

Constructors

Constructor	Description
ProcessContext()

Method Summary

Modifier and Type	Method	Description
abstract String	currentRecordId()
abstract Long	currentRecordOffset()
abstract InputT	element()	Returns the input element to be processed.
abstract PaneInfo	pane()	Returns information about the pane within this window into which the input element has been assigned.
abstract <T> T	sideInput(PCollectionView<T> view)	Returns the value of the side input.
abstract Instant	timestamp()	Returns the timestamp of the input element.

Methods inherited from class org.apache.beam.sdk.transforms.DoFn.WindowedContext

getPipelineOptions, output, output, outputWindowedValue, outputWindowedValue, outputWithTimestamp, outputWithTimestamp

Methods inherited from class java.lang.Object

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

Constructor Details

ProcessContext

public ProcessContext()

Method Details

element

@Pure
public abstract InputT element()

Returns the input element to be processed.

The element will not be changed -- it is safe to cache, etc. without copying. Implementation of DoFn.ProcessElement method should not mutate the element.

sideInput

@Pure
public abstract <T> T sideInput(PCollectionView<T> view)

Returns the value of the side input.

Throws:

IllegalArgumentException - if this is not a side input

See Also:

• ParDo.SingleOutput.withSideInputs(org.apache.beam.sdk.values.PCollectionView<?>...)

timestamp

@Pure
public abstract Instant timestamp()

Returns the timestamp of the input element.

See Window for more information.

pane

@Pure
public abstract PaneInfo pane()

Returns information about the pane within this window into which the input element has been assigned.

Generally all data is in a single, uninteresting pane unless custom triggering and/or late data has been explicitly requested. See Window for more information.

currentRecordId

@Pure
public abstract String currentRecordId()

currentRecordOffset

@Pure
public abstract Long currentRecordOffset()