@Internal public interface ExecutorFactory extends ComponentFactory
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
DataStream API and requires a pre configured
|Modifier and Type||Method and Description|
Creates a corresponding
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.