@Internal public final class DefaultExecutorFactory extends Object implements StreamExecutorFactory
Executor
for TableEnvironment
.
The unified TableEnvironment
will use create(Configuration)
method that does
not bind to any particular execution environment.
org.apache.flink.table.api.bridge.scala.StreamTableEnvironment
and StreamTableEnvironment
will use create(StreamExecutionEnvironment)
.
DEFAULT_IDENTIFIER
Constructor and Description |
---|
DefaultExecutorFactory() |
Modifier and Type | Method and Description |
---|---|
Executor |
create(Configuration configuration)
Creates a corresponding
Executor . |
Executor |
create(StreamExecutionEnvironment executionEnvironment)
Creates a corresponding
Executor . |
String |
factoryIdentifier()
Returns a unique identifier among same factory interfaces.
|
Set<ConfigOption<?>> |
optionalOptions()
Returns a set of
ConfigOption that an implementation of this factory consumes in
addition to Factory.requiredOptions() . |
Set<ConfigOption<?>> |
requiredOptions()
Returns a set of
ConfigOption that an implementation of this factory requires in
addition to Factory.optionalOptions() . |
public Executor create(Configuration configuration)
ExecutorFactory
Executor
.create
in interface ExecutorFactory
public Executor create(StreamExecutionEnvironment executionEnvironment)
StreamExecutorFactory
Executor
.
This method will be used when instantiating a TableEnvironment
from one of the
bridging modules which enables conversion from/to DataStream
API.
create
in interface StreamExecutorFactory
public String factoryIdentifier()
Factory
For consistency, an identifier should be declared as one lower case word (e.g. kafka
). If multiple factories exist for different versions, a version should be appended
using "-" (e.g. elasticsearch-7
).
factoryIdentifier
in interface Factory
public Set<ConfigOption<?>> requiredOptions()
Factory
ConfigOption
that an implementation of this factory requires in
addition to Factory.optionalOptions()
.
See the documentation of Factory
for more information.
requiredOptions
in interface Factory
public Set<ConfigOption<?>> optionalOptions()
Factory
ConfigOption
that an implementation of this factory consumes in
addition to Factory.requiredOptions()
.
See the documentation of Factory
for more information.
optionalOptions
in interface Factory
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.