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

Packages that use TableEnvironment

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

Uses of TableEnvironment in io.confluent.flink.plugin

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

Modifier and Type	Method	Description
static void	ConfluentTools.deleteArtifact(TableEnvironment env, String artifactId)	Deletes the artifact with the given id (e.g.
static void	ConfluentTools.deleteStatement(TableEnvironment env, String statementName)	Deletes the statement behind the given statement name, blocking until the deletion completes or the configured timeout (client.timeout) elapses.
static void	ConfluentTools.deleteStatement(TableEnvironment env, String statementName, boolean await)	Deletes the statement behind the given statement name, optionally waiting for the deletion to complete before returning.
static StatementHandle	StatementHandle.fromName(TableEnvironment env, String statementName)	Creates a handle to an existing Flink SQL statement on Confluent Cloud.
static StatementHandle	ConfluentTools.getStatementHandle(TableEnvironment env, String statementName)	Returns a StatementHandle to manage a submitted Flink SQL statement on Confluent Cloud.
static void	ConfluentTools.resumeStatement(TableEnvironment env, String statementName)	Resumes the statement behind the given statement name, blocking until the statement resumes or the configured timeout (client.timeout) elapses.
static void	ConfluentTools.resumeStatement(TableEnvironment env, String statementName, boolean await)	Resumes the statement behind the given statement name, optionally waiting for the statement to resume before returning.
static void	ConfluentTools.setStatementName(TableEnvironment env, String name)	Sets the statement name for the next statement submission.
static void	ConfluentTools.stopStatement(TableEnvironment env, String statementName)	Stops the statement behind the given statement name, blocking until the statement reaches a stopped state or the configured timeout (client.timeout) elapses.
static void	ConfluentTools.stopStatement(TableEnvironment env, String statementName, boolean await)	Stops the statement behind the given statement name, optionally waiting for the statement to reach a stopped state before returning.

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

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

Modifier and Type	Method	Description
static TableEnvironment	TableEnvironment.create(Configuration configuration)	Creates a table environment that is the entry point and central context for creating Table and SQL API programs.
static TableEnvironment	TableEnvironment.create(EnvironmentSettings settings)	Creates a table environment that is the entry point and central context for creating Table and SQL API programs.