Registry /
other / flink-table-api-java-bridge-2-11
This module contains the Table/SQL API for writing table programs that interact with other Flink APIs using the Java programming language.
Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
org.apache.flink.table.api.TableEnvironment
Minimal Flink Table API program creating a table and querying it.
import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.TableEnvironment;
public class FlinkTableExample {
public static void main(String[] args) {
EnvironmentSettings settings = EnvironmentSettings.newInstance().inStreamingMode().build();
TableEnvironment tEnv = TableEnvironment.create(settings);
tEnv.executeSql("CREATE TABLE source (id INT, name STRING) WITH ('connector' = 'datagen')");
tEnv.executeSql("SELECT * FROM source").print();
}
}
Upgrade
Version history
Breaking-change detection hasn't run for this library yet.
Audit
Security & dependencies
CVE tracking and dependency tree are planned for a later release.