Flink OpenSource SQL作业快速入门

  • 创建并提交Flink OpenSource SQL作业

    主要介绍创建并提交Flink OpenSource SQL作业的步骤和流程。

    主要介绍创建并提交Flink OpenSource SQL作业的步骤和流程。

  • 从Kafka读取数据写入到RDS

    主要介绍使用Flink opensource sql作业从Kafka读取数据写入到RDS。

    主要介绍使用Flink opensource sql作业从Kafka读取数据写入到RDS。

Flink OpenSource SQL作业的主推版本

  • Flink OpenSource SQL1.12

    主要介绍目前DLI所提供的Flink OpenSource SQL1.12语法。

    主要介绍目前DLI所提供的Flink OpenSource SQL1.12语法。

  • Flink OpenSource SQL1.10

    主要介绍目前DLI所提供的Flink OpenSource SQ1.10L语法

    主要介绍目前DLI所提供的Flink OpenSource SQ1.10L语法

常用的Flink Opensource SQL作业的语法

Flink Opensource SQL作业的语法:DDL语法定义、DML语法定义等。其中DDL定义语法包括,CREATE TABLE语句、CREATE VIEW语句、CREATE FUNCTION语句。

Flink Opensource SQL作业 进阶的语法:创建源表、创建结果表、创建维表、Format等,创建源表支持主流的各种源表,结果表也支持主流的结果表,创建维表同样也支持主流的各种维表。



Flink OpenSource SQL作业的开发指南

  • 从Kafka读取数据写入到DWS

    汽车驾驶的实时数据信息为数据源发送到Kafka中,再将Kafka数据的分析结果输出到DWS中。

    汽车驾驶的实时数据信息为数据源发送到Kafka中,再将Kafka数据的分析结果输出到DWS中

  • PostgreSQL CDC读取数据写入到DWS

    通过创建PostgreSQL CDC来监控Postgres的数据变化,并将数据信息插入到DWS数据库中。

    通过创建PostgreSQL CDC来监控Postgres的数据变化,并将数据信息插入到DWS数据库中。

  • JDBC或ODBC提交Spark SQL作业

    通过创建MySQL CDC源表来监控MySQL的数据变化,并将变化的数据信息插入到DWS数据库中。

    通过创建MySQL CDC源表来监控MySQL的数据变化,并将变化的数据信息插入到DWS数据库中。