org.apache.flink.table.client.config

Class Environment

java.lang.Object

org.apache.flink.table.client.config.Environment

public class Environment
extends Object

Environment configuration that represents the content of an environment file. Environment files define tables, execution, and deployment behavior. An environment might be defined by default or as part of a session. Environments can be merged or enriched with properties (e.g. from CLI command).

In future versions, we might restrict the merging or enrichment of deployment properties to not allow overwriting of a deployment by a session.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEPLOYMENT_ENTRY
static String	EXECUTION_ENTRY

Constructor Summary

Constructors

Constructor and Description
Environment()

Method Summary

Modifier and Type	Method and Description
static Environment	enrich(Environment env, Map<String,String> properties, Map<String,ViewEntry> views) Enriches an environment with new/modified properties or views and returns the new instance.
DeploymentEntry	getDeployment()
ExecutionEntry	getExecution()
Map<String,FunctionEntry>	getFunctions()
Map<String,TableEntry>	getTables()
static Environment	merge(Environment env1, Environment env2) Merges two environments.
static Environment	parse(String content) Parses an environment file from an String.
static Environment	parse(URL url) Parses an environment file from an URL.
void	setDeployment(Map<String,Object> config)
void	setExecution(Map<String,Object> config)
void	setFunctions(List<Map<String,Object>> functions)
void	setTables(List<Map<String,Object>> tables)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

EXECUTION_ENTRY

public static final String EXECUTION_ENTRY

See Also:

Constant Field Values

DEPLOYMENT_ENTRY

public static final String DEPLOYMENT_ENTRY

See Also:

Constant Field Values

Constructor Detail

Environment

public Environment()

Method Detail

getTables

public Map<String,TableEntry> getTables()

setTables

public void setTables(List<Map<String,Object>> tables)

getFunctions

public Map<String,FunctionEntry> getFunctions()

setFunctions

public void setFunctions(List<Map<String,Object>> functions)

setExecution

public void setExecution(Map<String,Object> config)

getExecution

public ExecutionEntry getExecution()

setDeployment

public void setDeployment(Map<String,Object> config)

getDeployment

public DeploymentEntry getDeployment()

toString

public String toString()

Overrides:

toString in class Object

parse

public static Environment parse(URL url)
                         throws IOException

Parses an environment file from an URL.

Throws:

IOException

parse

public static Environment parse(String content)
                         throws IOException

Parses an environment file from an String.

Throws:

IOException

merge

public static Environment merge(Environment env1,
                                Environment env2)

Merges two environments. The properties of the first environment might be overwritten by the second one.

enrich

public static Environment enrich(Environment env,
                                 Map<String,String> properties,
                                 Map<String,ViewEntry> views)

Enriches an environment with new/modified properties or views and returns the new instance.