Package org.apache.beam.runners.spark.translation

Class SparkProcessContext<K,InputT,OutputT>

java.lang.Object

org.apache.beam.runners.spark.translation.SparkProcessContext<K,InputT,OutputT>

public class SparkProcessContext<K,InputT,OutputT>
extends java.lang.Object

Holds current processing context for SparkInputDataProcessor.

Constructor Summary

Constructors

Constructor	Description
SparkProcessContext(java.lang.String stepName, org.apache.beam.sdk.transforms.DoFn<InputT,OutputT> doFn, org.apache.beam.runners.core.DoFnRunner<InputT,OutputT> doFnRunner, K key, java.util.Iterator<org.apache.beam.runners.core.TimerInternals.TimerData> timerDataIterator)

Method Summary

Modifier and Type	Method	Description
org.apache.beam.sdk.transforms.DoFn<InputT,OutputT>	getDoFn()
org.apache.beam.runners.core.DoFnRunner<InputT,OutputT>	getDoFnRunner()
K	getKey()
java.lang.String	getStepName()
java.util.Iterator<org.apache.beam.runners.core.TimerInternals.TimerData>	getTimerDataIterator()

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkProcessContext

public SparkProcessContext(java.lang.String stepName,
                           org.apache.beam.sdk.transforms.DoFn<InputT,OutputT> doFn,
                           org.apache.beam.runners.core.DoFnRunner<InputT,OutputT> doFnRunner,
                           K key,
                           java.util.Iterator<org.apache.beam.runners.core.TimerInternals.TimerData> timerDataIterator)

Method Detail

getStepName

public java.lang.String getStepName()

getDoFn

public org.apache.beam.sdk.transforms.DoFn<InputT,OutputT> getDoFn()

getDoFnRunner

public org.apache.beam.runners.core.DoFnRunner<InputT,OutputT> getDoFnRunner()

getTimerDataIterator

public java.util.Iterator<org.apache.beam.runners.core.TimerInternals.TimerData> getTimerDataIterator()

getKey

public K getKey()