@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
This method will be used when instantiating a
public Executor create(Map<String, String> properties, StreamExecutionEnvironment executionEnvironment);
TableEnvironmentfrom a bridging module which enables conversion from/to
DataStreamAPI and requires a pre configured
|Modifier and Type||Method and Description|
Creates a corresponding
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.