org.apache.beam.runners.twister2

Class Twister2TranslationContext

java.lang.Object

org.apache.beam.runners.twister2.Twister2TranslationContext

Direct Known Subclasses:

Twister2BatchTranslationContext, Twister2StreamingTranslationContext

public abstract class Twister2TranslationContext
extends java.lang.Object

Twister2TranslationContext.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<PValue,TSet<?>>	dataSets

Constructor Summary

Constructors

Constructor and Description
Twister2TranslationContext(Twister2PipelineOptions options)

Method Summary

Modifier and Type	Method and Description
abstract void	eval(SinkTSet<?> tSet)
void	execute()
<any>	getCurrentTransform()
TSetEnvironment	getEnvironment()
<T extends PValue> T	getInput(<any> transform)
<T> TSet<<any>>	getInputDataSet(PValue input)
<T> java.util.Map<<any>,PValue>	getInputs()
java.util.Set<TSet>	getLeaves()
PipelineOptions	getOptions()
<T extends PValue> T	getOutput(<any> transform)
java.util.Map<<any>,<any>>	getOutputCoders()
java.util.Map<<any>,PValue>	getOutputs()
SerializablePipelineOptions	getSerializableOptions()
java.util.Map<java.lang.String,BatchTSet<?>>	getSideInputDataSets()
void	setCurrentTransform(<any> transform)
<T> void	setOutputDataSet(<any> output, TSet<<any>> tset)
<VT,ET> void	setSideInputDataSet(java.lang.String value, BatchTSet<<any>> set)

Methods inherited from class java.lang.Object

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

Field Detail

dataSets

protected final java.util.Map<PValue,TSet<?>> dataSets

Constructor Detail

Twister2TranslationContext

public Twister2TranslationContext(Twister2PipelineOptions options)

Method Detail

getSerializableOptions

public SerializablePipelineOptions getSerializableOptions()

getOutput

public <T extends PValue> T getOutput(<any> transform)

getOptions

public PipelineOptions getOptions()

setOutputDataSet

public <T> void setOutputDataSet(<any> output,
                                 TSet<<any>> tset)

getInputDataSet

public <T> TSet<<any>> getInputDataSet(PValue input)

getInputs

public <T> java.util.Map<<any>,PValue> getInputs()

getInput

public <T extends PValue> T getInput(<any> transform)

setCurrentTransform

public void setCurrentTransform(<any> transform)

getCurrentTransform

public <any> getCurrentTransform()

getOutputs

public java.util.Map<<any>,PValue> getOutputs()

getOutputCoders

public java.util.Map<<any>,<any>> getOutputCoders()

getEnvironment

public TSetEnvironment getEnvironment()

execute

public void execute()

eval

public abstract void eval(SinkTSet<?> tSet)

setSideInputDataSet

public <VT,ET> void setSideInputDataSet(java.lang.String value,
                                        BatchTSet<<any>> set)

getLeaves

public java.util.Set<TSet> getLeaves()

getSideInputDataSets

public java.util.Map<java.lang.String,BatchTSet<?>> getSideInputDataSets()