Table API in Confluent Cloud for Apache Flink¶
Confluent Cloud for Apache Flink®️ supports programming applications with the Table API. For more information, see the Table API Overview. To get started with programming a streaming data application with the Table API, see the Java Table API Quick Start.
Confluent Cloud for Apache Flink supports the following Table API functions.
- TableEnvironment interface
- Table interface: SQL equivalents
- Table interface: API extensions
- TablePipeline interface
- StatementSet interface
- TableResult interface
- TableConfig class
- TableConfig class
- Confluent
- Others
TableEnvironment interface¶
- TableEnvironment.createStatementSet()
- TableEnvironment.createTable(String, TableDescriptor)
- TableEnvironment.executeSql(String)
- TableEnvironment.explainSql(String)
- TableEnvironment.from(String)
- TableEnvironment.fromValues(…)
- TableEnvironment.getConfig()
- TableEnvironment.getCurrentCatalog()
- TableEnvironment.getCurrentDatabase()
- TableEnvironment.listCatalogs()
- TableEnvironment.listDatabases()
- TableEnvironment.listFunctions()
- TableEnvironment.listTables()
- TableEnvironment.listTables(String, String)
- TableEnvironment.listViews()
- TableEnvironment.sqlQuery(String)
- TableEnvironment.useCatalog(String)
- TableEnvironment.useDatabase(String)
Table interface: SQL equivalents¶
- Table.as(…)
- Table.distinct()
- Table.executeInsert(String)
- Table.fetch(…)
- Table.filter(…)
- Table.fullOuterJoin(…)
- Table.groupBy(…)
- Table.insertInto(String)
- Table.intersect(…)
- Table.intersectAll(…)
- Table.join(…)
- Table.leftOuterJoin(…)
- Table.limit(…)
- Table.minus(…)
- Table.minusAll(…)
- Table.offset(…)
- Table.orderBy(…)
- Table.rightOuterJoin(…)
- Table.select(…)
- Table.union(…)
- Table.unionAll(…)
- Table.where(…)
- Table.window(…)
Table interface: API extensions¶
TablePipeline interface¶
StatementSet interface¶
TableResult interface¶
TableConfig class¶
Expressions class¶
- Expressions.* (except for
call()
)
Confluent¶
Confluent adds the following classes for more convenience:
- ConfluentSettings.*
- ConfluentTools.*
- ConfluentTableDescriptor.*