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 and Description
ExecutorImpl(DefaultContext defaultContext, InetSocketAddress gatewayAddress, String sessionId)
ExecutorImpl(DefaultContext defaultContext, InetSocketAddress gatewayAddress, String sessionId, RowFormat rowFormat)
ExecutorImpl(DefaultContext defaultContext, URL gatewayUrl, String sessionId)

Method Summary

Modifier and Type	Method and 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.
StatementResult	executeStatement(String statement) Execute statement.
ReadableConfig	getSessionConfig() Get the configuration of the session.
Map<String,String>	getSessionConfigMap() Get the map configuration of the session.
SessionHandle	getSessionHandle()

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.client.gateway.Executor

create, create, create

Constructor Detail

ExecutorImpl

public ExecutorImpl(DefaultContext defaultContext,
                    InetSocketAddress gatewayAddress,
                    String sessionId)

ExecutorImpl

public ExecutorImpl(DefaultContext defaultContext,
                    InetSocketAddress gatewayAddress,
                    String sessionId,
                    RowFormat rowFormat)

ExecutorImpl

public ExecutorImpl(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 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

close

public void close()

Description copied from interface: Executor

Close the Executor and process all exceptions.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Executor

getSessionHandle

@VisibleForTesting
public SessionHandle getSessionHandle()