org.apache.flink.table.delegation

Interface ExecutorFactory

All Superinterfaces:

ComponentFactory, TableFactory

All Known Implementing Classes:

BlinkExecutorFactory, StreamExecutorFactory

@Internal
public interface ExecutorFactory
extends ComponentFactory

Factory that creates Executor.

This factory is used with Java's Service Provider Interfaces (SPI) for discovering. A factory is called with a set of normalized properties that describe the desired configuration. Those properties may include execution configurations such as watermark interval, max parallelism etc., table specific initialization configuration such as if the queries should be executed in batch mode.

Important: The implementations of this interface should also implement method

  public Executor create(Map<String, String> properties, StreamExecutionEnvironment executionEnvironment);
 

This method will be used when instantiating a TableEnvironment from a bridging module which enables conversion from/to DataStream API and requires a pre configured StreamTableEnvironment.

Method Summary

Modifier and Type	Method and Description
Executor	create(Map<String,String> properties) Creates a corresponding Executor.

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

optionalContext, requiredContext, supportedProperties

Method Detail

create

Executor create(Map<String,String> properties)

Creates a corresponding Executor.

Parameters:

properties - Static properties of the Executor, the same that were used for factory lookup.

Returns:

instance of a Executor