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 java.lang.Object

Twister2TranslationContext.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
Twister2TranslationContext(Twister2PipelineOptions options)

Method Summary

Modifier and Type	Method and 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<org.apache.beam.sdk.util.WindowedValue<T>>	getInputDataSet(PValue input)
<T> java.util.Map<TupleTag<?>,PCollection<?>>	getInputs()
java.util.Set<edu.iu.dsc.tws.api.tset.sets.TSet>	getLeaves()
Twister2PipelineOptions	getOptions()
<T extends PValue> T	getOutput(PTransform<?,T> transform)
java.util.Map<TupleTag<?>,Coder<?>>	getOutputCoders()
java.util.Map<TupleTag<?>,PCollection<?>>	getOutputs()
java.util.Map<java.lang.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<org.apache.beam.sdk.util.WindowedValue<T>> tset)
<ViewT,ElemT> void	setSideInputDataSet(java.lang.String value, edu.iu.dsc.tws.api.tset.sets.batch.BatchTSet<org.apache.beam.sdk.util.WindowedValue<ElemT>> 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,edu.iu.dsc.tws.api.tset.sets.TSet<?>> dataSets

Constructor Detail

Twister2TranslationContext

public Twister2TranslationContext(Twister2PipelineOptions options)

Method Detail

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<org.apache.beam.sdk.util.WindowedValue<T>> tset)

getInputDataSet

public <T> edu.iu.dsc.tws.api.tset.sets.TSet<org.apache.beam.sdk.util.WindowedValue<T>> getInputDataSet(PValue input)

getInputs

public <T> java.util.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 java.util.Map<TupleTag<?>,PCollection<?>> getOutputs()

getOutputCoders

public java.util.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(java.lang.String value,
                                              edu.iu.dsc.tws.api.tset.sets.batch.BatchTSet<org.apache.beam.sdk.util.WindowedValue<ElemT>> set)

getLeaves

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

getSideInputDataSets

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