@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: In order to support DataStream APIs, implementations of this interface must
also implement StreamExecutorFactory
from the flink-table-api-bridge-base
module.
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–2024 The Apache Software Foundation. All rights reserved.