org.apache.flink.table.executor

Class StreamExecutor

java.lang.Object

org.apache.flink.table.executor.StreamExecutor

All Implemented Interfaces:

Executor

@Internal
public class StreamExecutor
extends Object
implements Executor

An implementation of Executor that is backed by a StreamExecutionEnvironment. This is the only executor that StreamPlanner supports.

Constructor Summary

Constructors

Constructor and Description
StreamExecutor(StreamExecutionEnvironment executionEnvironment)

Method Summary

Modifier and Type	Method and Description
Pipeline	createPipeline(List<Transformation<?>> transformations, TableConfig tableConfig, String jobName) Translates the given transformations to a Pipeline.
JobExecutionResult	execute(Pipeline pipeline) Executes the given pipeline.
JobClient	executeAsync(Pipeline pipeline) Executes the given pipeline asynchronously.
StreamExecutionEnvironment	getExecutionEnvironment()

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamExecutor

@VisibleForTesting
public StreamExecutor(StreamExecutionEnvironment executionEnvironment)

Method Detail

createPipeline

public Pipeline createPipeline(List<Transformation<?>> transformations,
                               TableConfig tableConfig,
                               String jobName)

Description copied from interface: Executor

Translates the given transformations to a Pipeline.

Specified by:

createPipeline in interface Executor

Parameters:

transformations - list of transformations

jobName - what should be the name of the job

Returns:

The pipeline representing the transformations.

execute

public JobExecutionResult execute(Pipeline pipeline)
                           throws Exception

Description copied from interface: Executor

Executes the given pipeline.

Specified by:

execute in interface Executor

Parameters:

pipeline - the pipeline to execute

Returns:

The result of the job execution, containing elapsed time and accumulators.

Throws:

Exception - which occurs during job execution.

executeAsync

public JobClient executeAsync(Pipeline pipeline)
                       throws Exception

Description copied from interface: Executor

Executes the given pipeline asynchronously.

Specified by:

executeAsync in interface Executor

Parameters:

pipeline - the pipeline to execute

Returns:

A JobClient that can be used to communicate with the submitted job, completed on submission succeeded.

Throws:

Exception - which occurs during job execution.

getExecutionEnvironment

public StreamExecutionEnvironment getExecutionEnvironment()