Uses of Interface
org.apache.flink.table.api.TableResult

Packages that use TableResult

Package	Description
io.confluent.flink.plugin
org.apache.flink.table.api

Uses of TableResult in io.confluent.flink.plugin

Methods in io.confluent.flink.plugin with parameters of type TableResult

Modifier and Type	Method	Description
static List<Row>	ConfluentTools.collectChangelog(TableResult tableResult)	Returns the given table results locally as a list of changelog rows.
static List<Row>	ConfluentTools.collectChangelog(TableResult tableResult, int stopAfter)	Returns the given table results locally as a list of changelog rows.
static List<Row>	ConfluentTools.collectMaterialized(TableResult tableResult)	Returns the given results locally as a materialized changelog.
static List<Row>	ConfluentTools.collectMaterialized(TableResult tableResult, int stopAfter)	Returns the given results locally as a materialized changelog.
static StatementHandle	StatementHandle.fromTableResult(TableResult tableResult)	Creates a handle to an existing Flink SQL statement on Confluent Cloud.
static StatementHandle	ConfluentTools.getStatementHandle(TableResult tableResult)	Returns a StatementHandle to manage a submitted Flink SQL statement on Confluent Cloud.
static String	ConfluentTools.getStatementName(TableResult tableResult)	Returns the statement name behind the given table result.
static void	ConfluentTools.printChangelog(TableResult tableResult)	Prints the results locally as a table prefixed with a change flag column.
static void	ConfluentTools.printChangelog(TableResult tableResult, int stopAfter)	Prints the given table results locally as a table prefixed with a change flag column.
static void	ConfluentTools.printMaterialized(TableResult tableResult)	Prints the given table results locally as a materialized changelog.
static void	ConfluentTools.printMaterialized(TableResult tableResult, int stopAfter)	Prints the given table results locally as a materialized changelog.
static void	ConfluentTools.stopStatement(TableResult tableResult)	Stops the statement behind the given table result, blocking until the statement reaches a stopped state or the configured timeout (client.timeout) elapses.
static void	ConfluentTools.stopStatement(TableResult tableResult, boolean await)	Stops the statement behind the given table result, optionally waiting for the statement to reach a stopped state before returning.

Uses of TableResult in org.apache.flink.table.api

Methods in org.apache.flink.table.api that return TableResult

Modifier and Type	Method	Description
TableResult	Executable.execute()	Executes this object.
TableResult	StatementSet.execute()	Executes this object.
default TableResult	Table.executeInsert(String tablePath)	Shorthand for tableEnv.insertInto(tablePath).execute().
default TableResult	Table.executeInsert(String tablePath, boolean overwrite)	Shorthand for tableEnv.insertInto(tablePath, overwrite).execute().
default TableResult	Table.executeInsert(String tablePath, InsertConflictStrategy conflictStrategy)	Shorthand for tableEnv.insertInto(tablePath, conflictStrategy).execute().
default TableResult	Table.executeInsert(String tablePath, InsertConflictStrategy conflictStrategy, boolean overwrite)	Shorthand for tableEnv.insertInto(tablePath, conflictStrategy, overwrite).execute().
default TableResult	Table.executeInsert(TableDescriptor descriptor)	Shorthand for tableEnv.insertInto(descriptor).execute().
default TableResult	Table.executeInsert(TableDescriptor descriptor, boolean overwrite)	Shorthand for tableEnv.insertInto(descriptor, overwrite).execute().
default TableResult	Table.executeInsert(TableDescriptor descriptor, InsertConflictStrategy conflictStrategy)	Shorthand for tableEnv.insertInto(descriptor, conflictStrategy).execute().
default TableResult	Table.executeInsert(TableDescriptor descriptor, InsertConflictStrategy conflictStrategy, boolean overwrite)	Shorthand for tableEnv.insertInto(descriptor, conflictStrategy, overwrite).execute().
default TableResult	TableEnvironment.executePlan(org.apache.flink.table.api.PlanReference planReference)	Shorthand for tEnv.loadPlan(planReference).execute().
TableResult	TableEnvironment.executeSql(String statement)	Executes the given single statement and returns the execution result.