org.apache.flink.table.client.cli

Class CliClient

java.lang.Object

org.apache.flink.table.client.cli.CliClient

public class CliClient
extends Object

SQL CLI client.

Constructor Summary

Constructors

Constructor and Description
CliClient(SessionContext context, Executor executor)

Method Summary

Modifier and Type	Method and Description
void	clearTerminal()
SessionContext	getContext()
Executor	getExecutor()
int	getHeight()
org.jline.terminal.Terminal	getTerminal()
int	getWidth()
boolean	isPlainTerminal()
void	open() Opens the interactive CLI shell.
boolean	submitUpdate(String statement) Submits a SQL update statement and prints status information and/or errors on the terminal.

Methods inherited from class java.lang.Object

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

Constructor Detail

CliClient

public CliClient(SessionContext context,
                 Executor executor)

Method Detail

getTerminal

public org.jline.terminal.Terminal getTerminal()

getContext

public SessionContext getContext()

clearTerminal

public void clearTerminal()

isPlainTerminal

public boolean isPlainTerminal()

getWidth

public int getWidth()

getHeight

public int getHeight()

getExecutor

public Executor getExecutor()

open

public void open()

Opens the interactive CLI shell.

submitUpdate

public boolean submitUpdate(String statement)

Submits a SQL update statement and prints status information and/or errors on the terminal.

Parameters:

statement - SQL update statement

Returns:

flag to indicate if the submission was successful or not