Package org.apache.flink.table.client.gateway

Class ExecutorImpl

java.lang.Object

org.apache.flink.table.client.gateway.ExecutorImpl

All Implemented Interfaces:

Closeable, AutoCloseable, Executor

public class ExecutorImpl
extends Object
implements Executor

Executor to connect to SqlGateway and execute statements.

Constructor Summary

Constructors

Constructor	Description
ExecutorImpl(org.apache.flink.table.gateway.service.context.DefaultContext defaultContext, InetSocketAddress gatewayAddress, String sessionId)
ExecutorImpl(org.apache.flink.table.gateway.service.context.DefaultContext defaultContext, InetSocketAddress gatewayAddress, String sessionId, org.apache.flink.table.gateway.rest.util.RowFormat rowFormat)
ExecutorImpl(org.apache.flink.table.gateway.service.context.DefaultContext defaultContext, URL gatewayUrl, String sessionId)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the Executor and process all exceptions.
List<String>	completeStatement(String statement, int position)	Returns a list of completion hints for the given statement at the given position.
void	configureSession(String statement)	Configures session with statement.
String	deployScript(String script, URI uri)	Deploy script in application mode.
StatementResult	executeStatement(String statement)	Execute statement.
org.apache.flink.configuration.ReadableConfig	getSessionConfig()	Get the configuration of the session.
Map<String,String>	getSessionConfigMap()	Get the map configuration of the session.
org.apache.flink.table.gateway.api.session.SessionHandle	getSessionHandle()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorImpl

public ExecutorImpl(org.apache.flink.table.gateway.service.context.DefaultContext defaultContext,
                    InetSocketAddress gatewayAddress,
                    String sessionId)

ExecutorImpl

public ExecutorImpl(org.apache.flink.table.gateway.service.context.DefaultContext defaultContext,
                    InetSocketAddress gatewayAddress,
                    String sessionId,
                    org.apache.flink.table.gateway.rest.util.RowFormat rowFormat)

ExecutorImpl

public ExecutorImpl(org.apache.flink.table.gateway.service.context.DefaultContext defaultContext,
                    URL gatewayUrl,
                    String sessionId)

Method Detail

configureSession

public void configureSession(String statement)

Description copied from interface: Executor

Configures session with statement.

Specified by:

configureSession in interface Executor

Parameters:

statement - to initialize the session

getSessionConfig

public org.apache.flink.configuration.ReadableConfig getSessionConfig()

Description copied from interface: Executor

Get the configuration of the session.

Specified by:

getSessionConfig in interface Executor

Returns:

the session configuration.

getSessionConfigMap

public Map<String,String> getSessionConfigMap()

Description copied from interface: Executor

Get the map configuration of the session.

Specified by:

getSessionConfigMap in interface Executor

Returns:

the map session configuration.

executeStatement

public StatementResult executeStatement(String statement)

Description copied from interface: Executor

Execute statement.

Specified by:

executeStatement in interface Executor

Parameters:

statement - to execute

Returns:

Iterable results of the statement

completeStatement

public List<String> completeStatement(String statement,
                                      int position)

Description copied from interface: Executor

Returns a list of completion hints for the given statement at the given position.

Specified by:

completeStatement in interface Executor

Parameters:

statement - Partial or slightly incorrect SQL statement

position - cursor position

Returns:

completion hints that fit at the current cursor position

deployScript

public String deployScript(@Nullable
                           String script,
                           @Nullable
                           URI uri)

Description copied from interface: Executor

Deploy script in application mode.

Specified by:

deployScript in interface Executor

Parameters:

script - content to run in application mode

uri - uri to the script

Returns:

the cluster id

close

public void close()

Description copied from interface: Executor

Close the Executor and process all exceptions.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Executor

getSessionHandle

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