@Internal public class BlinkExecutorFactory extends Object implements ExecutorFactory
Executor
to use in a
TableEnvironment
. The TableEnvironment
should use create(Map)
method that does not bind to any particular environment,
whereas StreamTableEnvironment
should use
create(Map, StreamExecutionEnvironment)
as it is always backed by
some StreamExecutionEnvironment
Constructor and Description |
---|
BlinkExecutorFactory() |
Modifier and Type | Method and Description |
---|---|
Executor |
create(Map<String,String> properties)
Creates a corresponding
Executor . |
Executor |
create(Map<String,String> properties,
StreamExecutionEnvironment executionEnvironment)
Creates a corresponding
ExecutorBase . |
Map<String,String> |
optionalContext()
Specifies a context of optional parameters that if exist should have the
given values.
|
Map<String,String> |
requiredContext()
Specifies the context that this factory has been implemented for.
|
List<String> |
supportedProperties()
List of property keys that this factory can handle.
|
public Executor create(Map<String,String> properties, StreamExecutionEnvironment executionEnvironment)
ExecutorBase
.properties
- Static properties of the Executor
, the same that were used for factory lookup.executionEnvironment
- a StreamExecutionEnvironment
to use while executing Table programs.Executor
public Executor create(Map<String,String> properties)
ExecutorFactory
Executor
.create
in interface ExecutorFactory
properties
- Static properties of the Executor
, the same that were used for factory lookup.Executor
public Map<String,String> requiredContext()
TableFactory
Typical properties might be: - connector.type - format.type
Specified property versions allow the framework to provide backwards compatible properties in case of string format changes: - connector.property-version - format.property-version
An empty context means that the factory matches for all requests.
requiredContext
in interface ComponentFactory
requiredContext
in interface TableFactory
public List<String> supportedProperties()
ComponentFactory
Example properties might be: - schema.#.type - schema.#.name - connector.topic - format.line-delimiter - format.ignore-parse-errors - format.fields.#.type - format.fields.#.name
Note: Use "#" to denote an array of values where "#" represents one or more digits. Property versions like "format.property-version" must not be part of the supported properties.
In some cases it might be useful to declare wildcards "*". Wildcards can only be declared at the end of a property key.
For example, if an arbitrary format should be supported: - format.*
Note: Wildcards should be used with caution as they might swallow unsupported properties and thus might lead to undesired behavior.
NOTE: All the property keys from ComponentFactory.optionalContext()
should also be included.
supportedProperties
in interface ComponentFactory
supportedProperties
in interface TableFactory
public Map<String,String> optionalContext()
ComponentFactory
ComponentFactory.requiredContext()
and ComponentFactory.supportedProperties()
.
NOTE: All the property keys should be included in ComponentFactory.supportedProperties()
.
optionalContext
in interface ComponentFactory
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.