org.apache.beam.runners.flink

Class FlinkBatchPortablePipelineTranslator.BatchTranslationContext

java.lang.Object

org.apache.beam.runners.flink.FlinkBatchPortablePipelineTranslator.BatchTranslationContext

All Implemented Interfaces:

FlinkPortablePipelineTranslator.TranslationContext

Enclosing class:

FlinkBatchPortablePipelineTranslator

public static class FlinkBatchPortablePipelineTranslator.BatchTranslationContext
extends java.lang.Object
implements FlinkPortablePipelineTranslator.TranslationContext

Batch translation context. Stores metadata about known PCollections/DataSets and holds the flink ExecutionEnvironment that the execution plan will be applied to.

Method Summary

Modifier and Type	Method and Description
<T> void	addDataSet(java.lang.String pCollectionId, org.apache.flink.api.java.DataSet<T> dataSet)
java.util.Collection<org.apache.flink.api.java.DataSet<?>>	getDanglingDataSets()
<T> org.apache.flink.api.java.DataSet<T>	getDataSetOrThrow(java.lang.String pCollectionId)
org.apache.flink.api.java.ExecutionEnvironment	getExecutionEnvironment()
JobInfo	getJobInfo()

Methods inherited from class java.lang.Object

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

Method Detail

getJobInfo

public JobInfo getJobInfo()

Specified by:

getJobInfo in interface FlinkPortablePipelineTranslator.TranslationContext

getExecutionEnvironment

public org.apache.flink.api.java.ExecutionEnvironment getExecutionEnvironment()

addDataSet

public <T> void addDataSet(java.lang.String pCollectionId,
                           org.apache.flink.api.java.DataSet<T> dataSet)

getDataSetOrThrow

public <T> org.apache.flink.api.java.DataSet<T> getDataSetOrThrow(java.lang.String pCollectionId)

getDanglingDataSets

public java.util.Collection<org.apache.flink.api.java.DataSet<?>> getDanglingDataSets()