Package org.apache.beam.runners.twister2

Class Twister2TranslationContext

java.lang.Object

org.apache.beam.runners.twister2.Twister2TranslationContext

Direct Known Subclasses:

Twister2BatchTranslationContext, Twister2StreamTranslationContext

public abstract class Twister2TranslationContext
extends Object

Twister2TranslationContext.

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<PValue,edu.iu.dsc.tws.api.tset.sets.TSet<?>>	dataSets

Constructor Summary

Constructors

Constructor	Description
Twister2TranslationContext(Twister2PipelineOptions options)

Method Summary

Modifier and Type	Method	Description
abstract void	eval(edu.iu.dsc.tws.tset.sets.batch.SinkTSet<?> tSet)
org.apache.beam.sdk.runners.AppliedPTransform<?,?,?>	getCurrentTransform()
edu.iu.dsc.tws.tset.env.TSetEnvironment	getEnvironment()
<T extends PValue> T	getInput(PTransform<T,?> transform)
<T> edu.iu.dsc.tws.api.tset.sets.TSet<WindowedValue<T>>	getInputDataSet(PValue input)
<T> Map<TupleTag<?>,PCollection<?>>	getInputs()
Set<edu.iu.dsc.tws.api.tset.sets.TSet>	getLeaves()
Twister2PipelineOptions	getOptions()
<T extends PValue> T	getOutput(PTransform<?,T> transform)
Map<TupleTag<?>,Coder<?>>	getOutputCoders()
Map<TupleTag<?>,PCollection<?>>	getOutputs()
Map<String,edu.iu.dsc.tws.api.tset.sets.batch.BatchTSet<?>>	getSideInputDataSets()
void	setCurrentTransform(org.apache.beam.sdk.runners.AppliedPTransform<?,?,?> transform)
<T> void	setOutputDataSet(PCollection<T> output, edu.iu.dsc.tws.api.tset.sets.TSet<WindowedValue<T>> tset)
<ViewT, ElemT> void	setSideInputDataSet(String value, edu.iu.dsc.tws.api.tset.sets.batch.BatchTSet<WindowedValue<ElemT>> set)

Methods inherited from class java.lang.Object

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

Field Details

dataSets

protected final Map<PValue,edu.iu.dsc.tws.api.tset.sets.TSet<?>> dataSets

Constructor Details

Twister2TranslationContext

public Twister2TranslationContext(Twister2PipelineOptions options)

Method Details

getOutput

public <T extends PValue> T getOutput(PTransform<?,T> transform)

getOptions

public Twister2PipelineOptions getOptions()

setOutputDataSet

public <T> void setOutputDataSet(PCollection<T> output,
 edu.iu.dsc.tws.api.tset.sets.TSet<WindowedValue<T>> tset)

getInputDataSet

public <T>
edu.iu.dsc.tws.api.tset.sets.TSet<WindowedValue<T>> getInputDataSet(PValue input)

getInputs

public <T> Map<TupleTag<?>,PCollection<?>> getInputs()

getInput

public <T extends PValue> T getInput(PTransform<T,?> transform)

setCurrentTransform

public void setCurrentTransform(org.apache.beam.sdk.runners.AppliedPTransform<?,?,?> transform)

getCurrentTransform

public org.apache.beam.sdk.runners.AppliedPTransform<?,?,?> getCurrentTransform()

getOutputs

public Map<TupleTag<?>,PCollection<?>> getOutputs()

getOutputCoders

public Map<TupleTag<?>,Coder<?>> getOutputCoders()

getEnvironment

public edu.iu.dsc.tws.tset.env.TSetEnvironment getEnvironment()

eval

public abstract void eval(edu.iu.dsc.tws.tset.sets.batch.SinkTSet<?> tSet)

setSideInputDataSet

public <ViewT,
ElemT> void setSideInputDataSet(String value,
 edu.iu.dsc.tws.api.tset.sets.batch.BatchTSet<WindowedValue<ElemT>> set)

getLeaves

public Set<edu.iu.dsc.tws.api.tset.sets.TSet> getLeaves()

getSideInputDataSets

public Map<String,edu.iu.dsc.tws.api.tset.sets.batch.BatchTSet<?>> getSideInputDataSets()