@Internal public interface ExecutorFactory extends Factory
Executor
for submitting table programs.
The factory is used with Java's Service Provider Interfaces (SPI) for discovering. See Factory
for more information.
Usually, there should only be one executor factory in the class path. However, advanced users can implement a custom one for hooking into the submission process.
Important: Implementations of this interface should also implement the method
public Executor create(Configuration, StreamExecutionEnvironment);
This method will be used when instantiating a TableEnvironment
from one of the
bridging modules which enables conversion from/to DataStream
API.
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_IDENTIFIER |
Modifier and Type | Method and Description |
---|---|
Executor |
create(Configuration configuration)
Creates a corresponding
Executor . |
factoryIdentifier, optionalOptions, requiredOptions
static final String DEFAULT_IDENTIFIER
Executor create(Configuration configuration)
Executor
.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.