org.apache.flink.table.gateway.service.context

Class SessionContext

java.lang.Object

org.apache.flink.table.gateway.service.context.SessionContext

public class SessionContext
extends Object

Context describing a session, it's mainly used for user to open a new session in the backend. If client request to open a new session, the backend Executor will maintain the session context map util users close it.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SessionContext.SessionState session state.

Method Summary

Modifier and Type	Method and Description
void	close() Close resources, e.g.
static SessionContext	create(DefaultContext defaultContext, SessionHandle sessionId, SessionEnvironment environment, ExecutorService operationExecutorService)
OperationExecutor	createOperationExecutor(Configuration executionConfig)
TableEnvironmentInternal	createTableEnvironment()
Map<String,String>	getConfigMap()
EndpointVersion	getEndpointVersion()
OperationManager	getOperationManager()
SessionHandle	getSessionId()
SessionContext.SessionState	getSessionState()
void	reset()
void	reset(String key)
void	set(String key, String value)

Methods inherited from class java.lang.Object

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

Method Detail

getSessionId

public SessionHandle getSessionId()

getConfigMap

public Map<String,String> getConfigMap()

getOperationManager

public OperationManager getOperationManager()

getEndpointVersion

public EndpointVersion getEndpointVersion()

getSessionState

public SessionContext.SessionState getSessionState()

set

public void set(String key,
                String value)

reset

public void reset(String key)

reset

public void reset()

createOperationExecutor

public OperationExecutor createOperationExecutor(Configuration executionConfig)

close

public void close()

Close resources, e.g. catalogs.

create

public static SessionContext create(DefaultContext defaultContext,
                                    SessionHandle sessionId,
                                    SessionEnvironment environment,
                                    ExecutorService operationExecutorService)

createTableEnvironment

public TableEnvironmentInternal createTableEnvironment()