org.apache.beam.runners.gearpump.translators

Class TranslationContext

java.lang.Object

org.apache.beam.runners.gearpump.translators.TranslationContext

public class TranslationContext
extends java.lang.Object

Maintains context data for TransformTranslators.

Constructor Summary

Constructors

Constructor and Description
TranslationContext(io.gearpump.streaming.dsl.javaapi.JavaStreamApp streamApp, GearpumpPipelineOptions pipelineOptions)

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.runners.AppliedPTransform<?,?,?>	getCurrentTransform()
PValue	getInput()
java.util.Map<TupleTag<?>,PValue>	getInputs()
<InputT> io.gearpump.streaming.dsl.javaapi.JavaStream<InputT>	getInputStream(PValue input)
PValue	getOutput()
java.util.Map<TupleTag<?>,PValue>	getOutputs()
GearpumpPipelineOptions	getPipelineOptions()
<T> io.gearpump.streaming.dsl.javaapi.JavaStream<T>	getSourceStream(io.gearpump.streaming.source.DataSource dataSource)
void	setCurrentTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node treeNode, Pipeline pipeline)
<OutputT> void	setOutputStream(PValue output, io.gearpump.streaming.dsl.javaapi.JavaStream<OutputT> outputStream)

Methods inherited from class java.lang.Object

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

Constructor Detail

TranslationContext

public TranslationContext(io.gearpump.streaming.dsl.javaapi.JavaStreamApp streamApp,
                          GearpumpPipelineOptions pipelineOptions)

Method Detail

setCurrentTransform

public void setCurrentTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node treeNode,
                                Pipeline pipeline)

getPipelineOptions

public GearpumpPipelineOptions getPipelineOptions()

getInputStream

public <InputT> io.gearpump.streaming.dsl.javaapi.JavaStream<InputT> getInputStream(PValue input)

setOutputStream

public <OutputT> void setOutputStream(PValue output,
                                      io.gearpump.streaming.dsl.javaapi.JavaStream<OutputT> outputStream)

getInputs

public java.util.Map<TupleTag<?>,PValue> getInputs()

getInput

public PValue getInput()

getOutputs

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

getOutput

public PValue getOutput()

getCurrentTransform

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

getSourceStream

public <T> io.gearpump.streaming.dsl.javaapi.JavaStream<T> getSourceStream(io.gearpump.streaming.source.DataSource dataSource)