public class Environment extends Object
In future versions, we might restrict the merging or enrichment of deployment properties to not allow overwriting of a deployment by a session.
Constructor and Description |
---|
Environment() |
Modifier and Type | Method and Description |
---|---|
static Environment |
enrich(Environment env,
Map<String,String> properties)
Enriches an environment with new/modified properties and returns the new instance.
|
Deployment |
getDeployment() |
Execution |
getExecution() |
Map<String,UserDefinedFunction> |
getFunctions() |
Map<String,org.apache.flink.table.descriptors.TableDescriptor> |
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() |
public Map<String,UserDefinedFunction> getFunctions()
public Execution getExecution()
public Deployment getDeployment()
public static Environment parse(URL url) throws IOException
IOException
public static Environment parse(String content) throws IOException
IOException
public static Environment merge(Environment env1, Environment env2)
public static Environment enrich(Environment env, Map<String,String> properties)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.