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()
FlinkPipelineOptions	getPipelineOptions()

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

getPipelineOptions

public FlinkPipelineOptions getPipelineOptions()

Specified by:

getPipelineOptions 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()