Package org.apache.flink.table.delegation

Interface StreamExecutorFactory

All Superinterfaces:

ExecutorFactory, Factory

All Known Implementing Classes:

DefaultExecutorFactory, DelegateExecutorFactory

@Internal
public interface StreamExecutorFactory
extends ExecutorFactory

Sub interface of ExecutorFactory to support DataStream API.

Field Summary

Fields inherited from interface org.apache.flink.table.delegation.ExecutorFactory

DEFAULT_IDENTIFIER

Method Summary

Modifier and Type	Method	Description
Executor	create(StreamExecutionEnvironment streamExecutionEnvironment)	Creates a corresponding Executor.

Methods inherited from interface org.apache.flink.table.delegation.ExecutorFactory

create

Methods inherited from interface org.apache.flink.table.factories.Factory

factoryIdentifier, optionalOptions, requiredOptions

Method Detail

create

Executor create(StreamExecutionEnvironment streamExecutionEnvironment)

Creates a corresponding Executor.

This method will be used when instantiating a TableEnvironment from one of the bridging modules which enables conversion from/to DataStream API.