Package | Description |
---|---|
org.apache.flink.table.client.cli | |
org.apache.flink.table.client.gateway | |
org.apache.flink.table.client.gateway.local |
Modifier and Type | Method and Description |
---|---|
SessionContext |
CliClient.getContext() |
Constructor and Description |
---|
CliClient(SessionContext context,
Executor executor)
Creates a CLI instance with a prepared terminal.
|
CliClient(org.jline.terminal.Terminal terminal,
SessionContext context,
Executor executor)
Creates a CLI instance with a custom terminal.
|
SqlCompleter(SessionContext context,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
SessionContext |
SessionContext.copy() |
Modifier and Type | Method and Description |
---|---|
void |
Executor.cancelQuery(SessionContext session,
String resultId)
Cancels a table program and stops the result retrieval.
|
List<String> |
Executor.completeStatement(SessionContext session,
String statement,
int position)
Returns a list of completion hints for the given statement at the given position.
|
ResultDescriptor |
Executor.executeQuery(SessionContext session,
String query)
Submits a Flink SQL query job (detached) and returns the result descriptor.
|
ProgramTargetDescriptor |
Executor.executeUpdate(SessionContext session,
String statement)
Submits a Flink SQL update statement such as INSERT INTO.
|
String |
Executor.explainStatement(SessionContext session,
String statement)
Returns a string-based explanation about AST and execution plan of the given statement.
|
Map<String,String> |
Executor.getSessionProperties(SessionContext session)
Lists all session properties that are defined by the executor and the session.
|
TableSchema |
Executor.getTableSchema(SessionContext session,
String name)
Returns the schema of a table.
|
List<String> |
Executor.listTables(SessionContext session)
Lists all tables known to the executor.
|
List<String> |
Executor.listUserDefinedFunctions(SessionContext session)
Lists all user-defined functions known to the executor.
|
TypedResult<List<Tuple2<Boolean,Row>>> |
Executor.retrieveResultChanges(SessionContext session,
String resultId)
Asks for the next changelog results (non-blocking).
|
TypedResult<Integer> |
Executor.snapshotResult(SessionContext session,
String resultId,
int pageSize)
Creates an immutable result snapshot of the running Flink job.
|
void |
Executor.stop(SessionContext session)
Stops the executor.
|
void |
Executor.validateSession(SessionContext session)
Validates the current session.
|
Modifier and Type | Method and Description |
---|---|
SessionContext |
ExecutionContext.getSessionContext() |
Constructor and Description |
---|
ExecutionContext(Environment defaultEnvironment,
SessionContext sessionContext,
List<URL> dependencies,
Configuration flinkConfig,
org.apache.commons.cli.Options commandLineOptions,
List<CustomCommandLine<?>> availableCommandLines) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.