Package 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	Description
static class	SessionContext.SessionState	session state.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SessionContext(DefaultContext defaultContext, org.apache.flink.table.gateway.api.session.SessionHandle sessionId, org.apache.flink.table.gateway.api.endpoint.EndpointVersion endpointVersion, org.apache.flink.configuration.Configuration sessionConf, URLClassLoader classLoader, SessionContext.SessionState sessionState, OperationManager operationManager)

Method Summary

Modifier and Type	Method	Description
void	addStatementSetOperation(org.apache.flink.table.operations.ModifyOperation operation)
void	close()	Close resources, e.g. catalogs.
static SessionContext	create(DefaultContext defaultContext, org.apache.flink.table.gateway.api.session.SessionHandle sessionId, org.apache.flink.table.gateway.api.session.SessionEnvironment environment, ExecutorService operationExecutorService)
OperationExecutor	createOperationExecutor(org.apache.flink.configuration.Configuration executionConfig)
void	disableStatementSet()
void	enableStatementSet()
DefaultContext	getDefaultContext()
org.apache.flink.table.gateway.api.endpoint.EndpointVersion	getEndpointVersion()
OperationManager	getOperationManager()
org.apache.flink.table.api.internal.PlanCacheManager	getPlanCacheManager()
org.apache.flink.configuration.Configuration	getSessionConf()
org.apache.flink.table.gateway.api.session.SessionHandle	getSessionId()
SessionContext.SessionState	getSessionState()
List<org.apache.flink.table.operations.ModifyOperation>	getStatementSetOperations()
URLClassLoader	getUserClassloader()
protected static org.apache.flink.configuration.Configuration	initializeConfiguration(DefaultContext defaultContext, org.apache.flink.table.gateway.api.session.SessionEnvironment environment, org.apache.flink.table.gateway.api.session.SessionHandle sessionId)
protected static SessionContext.SessionState	initializeSessionState(org.apache.flink.table.gateway.api.session.SessionEnvironment environment, org.apache.flink.configuration.Configuration configuration, org.apache.flink.table.resource.ResourceManager resourceManager)
boolean	isStatementSetState()
void	open()
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

Constructor Detail

SessionContext

protected SessionContext(DefaultContext defaultContext,
                         org.apache.flink.table.gateway.api.session.SessionHandle sessionId,
                         org.apache.flink.table.gateway.api.endpoint.EndpointVersion endpointVersion,
                         org.apache.flink.configuration.Configuration sessionConf,
                         URLClassLoader classLoader,
                         SessionContext.SessionState sessionState,
                         OperationManager operationManager)

Method Detail

getSessionId

public org.apache.flink.table.gateway.api.session.SessionHandle getSessionId()

getSessionConf

public org.apache.flink.configuration.Configuration getSessionConf()

getOperationManager

public OperationManager getOperationManager()

getEndpointVersion

public org.apache.flink.table.gateway.api.endpoint.EndpointVersion getEndpointVersion()

getSessionState

public SessionContext.SessionState getSessionState()

getDefaultContext

public DefaultContext getDefaultContext()

getUserClassloader

public URLClassLoader getUserClassloader()

getPlanCacheManager

@Nullable
public org.apache.flink.table.api.internal.PlanCacheManager getPlanCacheManager()

set

public void set(String key,
                String value)

reset

public void reset(String key)

reset

public void reset()

createOperationExecutor

public OperationExecutor createOperationExecutor(org.apache.flink.configuration.Configuration executionConfig)

isStatementSetState

public boolean isStatementSetState()

enableStatementSet

public void enableStatementSet()

disableStatementSet

public void disableStatementSet()

getStatementSetOperations

public List<org.apache.flink.table.operations.ModifyOperation> getStatementSetOperations()

addStatementSetOperation

public void addStatementSetOperation(org.apache.flink.table.operations.ModifyOperation operation)

open

public void open()

close

public void close()

Close resources, e.g. catalogs.

create

public static SessionContext create(DefaultContext defaultContext,
                                    org.apache.flink.table.gateway.api.session.SessionHandle sessionId,
                                    org.apache.flink.table.gateway.api.session.SessionEnvironment environment,
                                    ExecutorService operationExecutorService)

initializeConfiguration

protected static org.apache.flink.configuration.Configuration initializeConfiguration(DefaultContext defaultContext,
                                                                                      org.apache.flink.table.gateway.api.session.SessionEnvironment environment,
                                                                                      org.apache.flink.table.gateway.api.session.SessionHandle sessionId)

initializeSessionState

protected static SessionContext.SessionState initializeSessionState(org.apache.flink.table.gateway.api.session.SessionEnvironment environment,
                                                                    org.apache.flink.configuration.Configuration configuration,
                                                                    org.apache.flink.table.resource.ResourceManager resourceManager)