org.apache.flink.table.api

Class EnvironmentSettings.Builder

java.lang.Object

org.apache.flink.table.api.EnvironmentSettings.Builder

Enclosing class:

EnvironmentSettings

public static class EnvironmentSettings.Builder
extends Object

A builder for EnvironmentSettings.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
EnvironmentSettings	build() Returns an immutable instance of EnvironmentSettings.
EnvironmentSettings.Builder	inBatchMode() Sets that the components should work in a batch mode.
EnvironmentSettings.Builder	inStreamingMode() Sets that the components should work in a streaming mode.
EnvironmentSettings.Builder	useAnyPlanner() Deprecated. The old planner has been removed in Flink 1.14. Since there is only one planner left (previously called the 'blink' planner), this setting is obsolete and will be removed in future versions.
EnvironmentSettings.Builder	useBlinkPlanner() Deprecated. The old planner has been removed in Flink 1.14. Since there is only one planner left (previously called the 'blink' planner), this setting is obsolete and will be removed in future versions.
EnvironmentSettings.Builder	useOldPlanner() Deprecated. The old planner has been removed in Flink 1.14. Since there is only one planner left (previously called the 'blink' planner), this setting will throw an exception.
EnvironmentSettings.Builder	withBuiltInCatalogName(String builtInCatalogName) Specifies the name of the initial catalog to be created when instantiating a TableEnvironment.
EnvironmentSettings.Builder	withBuiltInDatabaseName(String builtInDatabaseName) Specifies the name of the default database in the initial catalog to be created when instantiating a TableEnvironment.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

useOldPlanner

@Deprecated
public EnvironmentSettings.Builder useOldPlanner()

Deprecated. The old planner has been removed in Flink 1.14. Since there is only one planner left (previously called the 'blink' planner), this setting will throw an exception.

useBlinkPlanner

@Deprecated
public EnvironmentSettings.Builder useBlinkPlanner()

Deprecated. The old planner has been removed in Flink 1.14. Since there is only one planner left (previously called the 'blink' planner), this setting is obsolete and will be removed in future versions.

Sets the Blink planner as the required module.

This is the default behavior.

useAnyPlanner

@Deprecated
public EnvironmentSettings.Builder useAnyPlanner()

Deprecated. The old planner has been removed in Flink 1.14. Since there is only one planner left (previously called the 'blink' planner), this setting is obsolete and will be removed in future versions.

Does not set a planner requirement explicitly.

A planner will be discovered automatically, if there is only one planner available.

By default, useBlinkPlanner() is enabled.

inBatchMode

public EnvironmentSettings.Builder inBatchMode()

Sets that the components should work in a batch mode. Streaming mode by default.

inStreamingMode

public EnvironmentSettings.Builder inStreamingMode()

Sets that the components should work in a streaming mode. Enabled by default.

withBuiltInCatalogName

public EnvironmentSettings.Builder withBuiltInCatalogName(String builtInCatalogName)

Specifies the name of the initial catalog to be created when instantiating a TableEnvironment.

This catalog is an in-memory catalog that will be used to store all temporary objects (e.g. from TableEnvironment.createTemporaryView(String, Table) or TableEnvironment.createTemporarySystemFunction(String, UserDefinedFunction)) that cannot be persisted because they have no serializable representation.

It will also be the initial value for the current catalog which can be altered via TableEnvironment.useCatalog(String).

Default: "default_catalog".

withBuiltInDatabaseName

public EnvironmentSettings.Builder withBuiltInDatabaseName(String builtInDatabaseName)

Specifies the name of the default database in the initial catalog to be created when instantiating a TableEnvironment.

This database is an in-memory database that will be used to store all temporary objects (e.g. from TableEnvironment.createTemporaryView(String, Table) or TableEnvironment.createTemporarySystemFunction(String, UserDefinedFunction)) that cannot be persisted because they have no serializable representation.

It will also be the initial value for the current database which can be altered via TableEnvironment.useDatabase(String).

Default: "default_database".

build

public EnvironmentSettings build()

Returns an immutable instance of EnvironmentSettings.