Package org.apache.beam.runners.flink

Class FlinkBatchPortablePipelineTranslator.BatchTranslationContext

java.lang.Object

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

All Implemented Interfaces:

FlinkPortablePipelineTranslator.Executor, FlinkPortablePipelineTranslator.TranslationContext

Enclosing class:

FlinkBatchPortablePipelineTranslator

public static class FlinkBatchPortablePipelineTranslator.BatchTranslationContext
extends Object
implements FlinkPortablePipelineTranslator.TranslationContext, FlinkPortablePipelineTranslator.Executor

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	Description
<T> void	addDataSet(String pCollectionId, org.apache.flink.api.java.DataSet<T> dataSet)
org.apache.flink.api.common.JobExecutionResult	execute(String jobName)
Collection<org.apache.flink.api.java.DataSet<?>>	getDanglingDataSets()
<T> org.apache.flink.api.java.DataSet<T>	getDataSetOrThrow(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 Details

getJobInfo

public JobInfo getJobInfo()

Specified by:

getJobInfo in interface FlinkPortablePipelineTranslator.TranslationContext

getPipelineOptions

public FlinkPipelineOptions getPipelineOptions()

Specified by:

getPipelineOptions in interface FlinkPortablePipelineTranslator.TranslationContext

execute

public org.apache.flink.api.common.JobExecutionResult execute(String jobName)
                                                       throws Exception

Specified by:

execute in interface FlinkPortablePipelineTranslator.Executor

Throws:

Exception

getExecutionEnvironment

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

addDataSet

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

getDataSetOrThrow

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

getDanglingDataSets

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