Table API & SQL

    The Table API and SQL interfaces integrate seamlessly with each other and Flink’s DataStream API. You can easily switch between all APIs and libraries which build upon them. For instance, you can detect patterns from a table using MATCH_RECOGNIZE clause and later use the DataStream API to build alerting based on the matched patterns.

    Java

    Python

    If you want to implement a for (de)serializing rows or a set of user-defined functions, the following dependency is sufficient and can be used for JAR files for the SQL Client:

    Where to go next?

    • Data Types: Lists pre-defined data types and their properties.
    • : Streaming-specific documentation for the Table API or SQL such as configuration of time attributes and handling of updating results.
    • Connect to External Systems: Available connectors and formats for reading and writing data to external systems.
    • : Supported operations and syntax for SQL.
    • Built-in Functions: Supported functions in Table API and SQL.
    • : Play around with Flink SQL and submit a table program to a cluster without programming knowledge.