@PublicEvolving public class EnvironmentSettings extends Object
TableEnvironment
and cannot be changed afterwards.
Example:
EnvironmentSettings.newInstance()
.useOldPlanner()
.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 |
---|---|
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 |
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 . |
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 String getBuiltInCatalogName()
TableEnvironment
.public String getBuiltInDatabaseName()
TableEnvironment
.public boolean isStreamingMode()
TableEnvironment
should work in a batch or streaming mode.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.