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.

Flink Table Java API

The following links open the associated javadocs.

• Table API

  • TableEnvironment

  • Table

  • TablePipeline.execute()

  • TablePipeline.explain()

  • TablePipeline.printExplain()

  • StatementSet

  • TableResult

  • TableConfig.set(…)

  • Expressions.* (except for call())

  • FormatDescriptor.*

  • TableDescriptor.*

  • Over.*

  • Session.*

  • Slide.*

  • Tumble.*

Confluent APIs

Confluent adds the following APIs for more convenience. The following links open the associated javadocs.

• Confluent Table Plugin API

  • ConfluentSettings.*

  • ConfluentTools.*

  • ConfluentTableDescriptor.*

  • ConfluentMLExpressions.*

  • StatementHandle.*

Process Table Function (PTF) Test Harness API

Confluent ships the PTF test harness with the Table API for more convenience. The following links open the associated javadocs.

• ProcessTableFunctionTestHarness

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.