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

Class 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.

    • Method Detail

      • touch

        public void touch()

      • getLastAccessTime

        public long getLastAccessTime()

      • getSessionHandle

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

      • getEndpointVersion

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

      • createExecutor

        public OperationExecutor createExecutor​(org.apache.flink.configuration.Configuration executionConfig)

      • getPlanCacheManager

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