Package org.apache.beam.runners.flink

Class FlinkStreamingPortablePipelineTranslator.StreamingTranslationContext

java.lang.Object

org.apache.beam.runners.flink.FlinkStreamingPortablePipelineTranslator.StreamingTranslationContext

All Implemented Interfaces:

FlinkPortablePipelineTranslator.Executor, FlinkPortablePipelineTranslator.TranslationContext

Enclosing class:

FlinkStreamingPortablePipelineTranslator

public static class FlinkStreamingPortablePipelineTranslator.StreamingTranslationContext
extends Object
implements FlinkPortablePipelineTranslator.TranslationContext, FlinkPortablePipelineTranslator.Executor

Streaming translation context. Stores metadata about known PCollections/DataStreams and holds the Flink StreamExecutionEnvironment that the execution plan will be applied to.

Method Summary

Modifier and Type	Method	Description
<T> void	addDataStream(String pCollectionId, org.apache.flink.streaming.api.datastream.DataStream<T> dataStream)
org.apache.flink.api.common.JobExecutionResult	execute(String jobName)
<T> org.apache.flink.streaming.api.datastream.DataStream<T>	getDataStreamOrThrow(String pCollectionId)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	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.streaming.api.environment.StreamExecutionEnvironment getExecutionEnvironment()

addDataStream

public <T> void addDataStream(String pCollectionId,
 org.apache.flink.streaming.api.datastream.DataStream<T> dataStream)

getDataStreamOrThrow

public <T>
org.apache.flink.streaming.api.datastream.DataStream<T> getDataStreamOrThrow(String pCollectionId)