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

• Expressions 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.