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 java.lang.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 and Description
<T> void	addDataStream(java.lang.String pCollectionId, org.apache.flink.streaming.api.datastream.DataStream<T> dataStream)
org.apache.flink.api.common.JobExecutionResult	execute(java.lang.String jobName)
<T> org.apache.flink.streaming.api.datastream.DataStream<T>	getDataStreamOrThrow(java.lang.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 Detail

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(java.lang.String jobName)
                                                       throws java.lang.Exception

Specified by:

execute in interface FlinkPortablePipelineTranslator.Executor

Throws:

java.lang.Exception

getExecutionEnvironment

public org.apache.flink.streaming.api.environment.StreamExecutionEnvironment getExecutionEnvironment()

addDataStream

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

getDataStreamOrThrow

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