@PublicEvolving public class EnvironmentSettings extends Object
TableEnvironment
and cannot be changed afterwards.
Example:
EnvironmentSettings.newInstance()
.useBlinkPlanner()
.inStreamingMode()
.withBuiltInCatalogName("default_catalog")
.withBuiltInDatabaseName("default_database")
.build()
Modifier and Type | Class and Description |
---|---|
static class |
EnvironmentSettings.Builder
A builder for
EnvironmentSettings . |
Modifier and Type | Field and Description |
---|---|
static String |
CLASS_NAME |
static String |
DEFAULT_BUILTIN_CATALOG |
static String |
DEFAULT_BUILTIN_DATABASE |
static String |
STREAMING_MODE |
Modifier and Type | Method and Description |
---|---|
static EnvironmentSettings |
fromConfiguration(Configuration configuration)
Creates an instance of
EnvironmentSettings from Configuration . |
String |
getBuiltInCatalogName()
Gets the specified name of the initial catalog to be created when instantiating a
TableEnvironment . |
String |
getBuiltInDatabaseName()
Gets the specified name of the default database in the initial catalog to be created when
instantiating a
TableEnvironment . |
boolean |
isBlinkPlanner()
Tells if the
TableEnvironment should work in the blink planner or old planner. |
boolean |
isStreamingMode()
Tells if the
TableEnvironment should work in a batch or streaming mode. |
static EnvironmentSettings.Builder |
newInstance()
Creates a builder for creating an instance of
EnvironmentSettings . |
Configuration |
toConfiguration()
Convert the environment setting to the
Configuration . |
Map<String,String> |
toExecutorProperties() |
Map<String,String> |
toPlannerProperties() |
public static final String STREAMING_MODE
public static final String CLASS_NAME
public static final String DEFAULT_BUILTIN_CATALOG
public static final String DEFAULT_BUILTIN_DATABASE
public static EnvironmentSettings.Builder newInstance()
EnvironmentSettings
.
By default, it does not specify a required planner and will use the one that is available on the classpath via discovery.
public static EnvironmentSettings fromConfiguration(Configuration configuration)
EnvironmentSettings
from Configuration
.public Configuration toConfiguration()
Configuration
.public String getBuiltInCatalogName()
TableEnvironment
.public String getBuiltInDatabaseName()
TableEnvironment
.public boolean isStreamingMode()
TableEnvironment
should work in a batch or streaming mode.public boolean isBlinkPlanner()
TableEnvironment
should work in the blink planner or old planner.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.