org.apache.flink.table.client.gateway

Class SingleSessionManager

java.lang.Object

org.apache.flink.table.client.gateway.SingleSessionManager

All Implemented Interfaces:

SessionManager

public class SingleSessionManager
extends Object
implements SessionManager

A SessionManager only has one session at most. It uses the less resources and also provides special handler for the REMOVE JAR syntax.

The special SessionManager is used in the Sql Client embedded mode and doesn't support concurrently modification.

Constructor Summary

Constructors

Constructor and Description
SingleSessionManager(DefaultContext defaultContext)

Method Summary

Modifier and Type	Method and Description
void	closeSession(SessionHandle sessionHandle) Close the session with the specified identifier and releases the resources used by the session.
Session	getSession(SessionHandle sessionHandle) Get the Session with the identifier.
Session	openSession(SessionEnvironment environment) Register a new Session.
void	start() Start the SessionManager and do the required initialization.
void	stop() Destroy the SessionManager and releases used resources.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.gateway.service.session.SessionManager

create

Constructor Detail

SingleSessionManager

public SingleSessionManager(DefaultContext defaultContext)

Method Detail

start

public void start()

Description copied from interface: SessionManager

Start the SessionManager and do the required initialization.

Specified by:

start in interface SessionManager

stop

public void stop()

Description copied from interface: SessionManager

Destroy the SessionManager and releases used resources.

Specified by:

stop in interface SessionManager

getSession

public Session getSession(SessionHandle sessionHandle)
                   throws SqlGatewayException

Description copied from interface: SessionManager

Get the Session with the identifier.

Specified by:

getSession in interface SessionManager

Parameters:

sessionHandle - identifier of the session.

Returns:

registered session.

Throws:

SqlGatewayException

openSession

public Session openSession(SessionEnvironment environment)
                    throws SqlGatewayException

Description copied from interface: SessionManager

Register a new Session.

Specified by:

openSession in interface SessionManager

Parameters:

environment - the initialization environment.

Returns:

created session.

Throws:

SqlGatewayException

closeSession

public void closeSession(SessionHandle sessionHandle)
                  throws SqlGatewayException

Description copied from interface: SessionManager

Close the session with the specified identifier and releases the resources used by the session.

Specified by:

closeSession in interface SessionManager

Parameters:

sessionHandle - the identifier of the session.

Throws:

SqlGatewayException