org.apache.flink.table.gateway.service.session

Class Session

java.lang.Object

org.apache.flink.table.gateway.service.session.Session

All Implemented Interfaces:

Closeable, AutoCloseable

public class Session
extends Object
implements Closeable

Similar to HTTP Session, which could maintain user identity and store user-specific data during multiple request/response interactions between a client and the gateway server.

Constructor Summary

Constructors

Constructor and Description
Session(SessionContext sessionContext)

Method Summary

Modifier and Type	Method and Description
void	close()
OperationExecutor	createExecutor()
OperationExecutor	createExecutor(Configuration executionConfig)
EndpointVersion	getEndpointVersion()
long	getLastAccessTime()
OperationManager	getOperationManager()
PlanCacheManager	getPlanCacheManager()
Map<String,String>	getSessionConfig()
SessionHandle	getSessionHandle()
void	open()
void	touch()

Methods inherited from class java.lang.Object

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

Constructor Detail

Session

public Session(SessionContext sessionContext)

Method Detail

touch

public void touch()

getLastAccessTime

public long getLastAccessTime()

getSessionHandle

public SessionHandle getSessionHandle()

getSessionConfig

public Map<String,String> getSessionConfig()

getEndpointVersion

public EndpointVersion getEndpointVersion()

getOperationManager

public OperationManager getOperationManager()

createExecutor

public OperationExecutor createExecutor()

createExecutor

public OperationExecutor createExecutor(Configuration executionConfig)

getPlanCacheManager

@Nullable
public PlanCacheManager getPlanCacheManager()

open

public void open()

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable