Skip to main content

Table API

Dynamic tables and continuous queries

In Flink SQL, a table is a structured representation of data that can be queried using SQL syntax. Tables can be created from various sources such as streams, files, or other tables. To create a table, you register metadata to connect to the system you want to use, such as Kafka. Dynamic tables process streaming data and continuously update their results to reflect changes on input tables. The underlying data of a dynamic table is stored in the storage layer, which in this example is Kafka.


Transforming a stream to a dynamic table:

transforming-stream-to-dynamic-table.png

Querying a dynamic table and sending the result of the continuous query to another dynamic table:

querying-dynamic-table-to-another-dynamic-table.png

Example

Stream-table duality