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

• Table.addColumns(…)
• Table.addOrReplaceColumns(…)
• Table.dropColumns(…)
• Table.execute()
• Table.explain()
• Table.getResolvedSchema()
• Table.map(…)
• Table.printExplain()
• Table.printSchema()
• Table.renameColumns(…)

TablePipeline interface

• TablePipeline.execute()
• TablePipeline.explain()
• TablePipeline.printExplain()

StatementSet interface

• StatementSet.add(TablePipeline)
• StatementSet.addInsert(String, Table)
• StatementSet.addInsertSql(String)
• StatementSet.execute()
• StatementSet.explain()

TableResult interface

• TableResult.await(…)
• TableResult.collect()
• TableResult.getJobClient().cancel()
• TableResult.getResolvedSchema()
• TableResult.print()

TableConfig class

• TableConfig.set(…)

Expressions class

• Expressions.* (except for call())

Others

• FormatDescriptor.*
• TableDescriptor.*
• Over.*
• Session.*
• Slide.*
• Tumble.*

Confluent

Confluent adds the following classes for more convenience:

• ConfluentSettings.*
• ConfluentTools.*
• ConfluentTableDescriptor.*

Related content

• Course: Apache Flink® Table API: Processing Data Streams in Java
• Table API Overview
• Java Table API Quick Start

Note

This website includes content developed at the Apache Software Foundation under the terms of the Apache License v2.