org.apache.flink.table.client.gateway.local

Class ExecutionContext.EnvironmentInstance

java.lang.Object

org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance

Enclosing class:

ExecutionContext<T>

public class ExecutionContext.EnvironmentInstance
extends Object

ExecutionEnvironment and StreamExecutionEnvironment cannot be reused across multiple queries because they are stateful. This class abstracts execution environments and table environments.

Method Summary

Modifier and Type	Method and Description
JobGraph	createJobGraph(String name)
ExecutionConfig	getExecutionConfig()
ExecutionEnvironment	getExecutionEnvironment()
QueryConfig	getQueryConfig()
StreamExecutionEnvironment	getStreamExecutionEnvironment()
org.apache.flink.table.api.TableEnvironment	getTableEnvironment()

Methods inherited from class java.lang.Object

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

Method Detail

getQueryConfig

public QueryConfig getQueryConfig()

getExecutionEnvironment

public ExecutionEnvironment getExecutionEnvironment()

getStreamExecutionEnvironment

public StreamExecutionEnvironment getStreamExecutionEnvironment()

getTableEnvironment

public org.apache.flink.table.api.TableEnvironment getTableEnvironment()

getExecutionConfig

public ExecutionConfig getExecutionConfig()

createJobGraph

public JobGraph createJobGraph(String name)