flink 1.10 sql 方式读取 mysql

╰+哭是因爲堅強的太久メ 2022-12-19 01:22 85阅读 0赞

## ddl 方式 ##

package com.jq.wc
    
    import org.apache.flink.streaming.api.scala._
    import org.apache.flink.table.api.Table
    import org.apache.flink.table.api.scala._
    object MysqlSource { 
      def main(args: Array[String]): Unit = { 
    
        val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
        val tableEnv: StreamTableEnvironment = StreamTableEnvironment.create(env)
    
        val createTableSql = """CREATE TABLE story ( | id BIGINT, | title STRING |) WITH ( | 'connector.type' = 'jdbc', | 'connector.url' = 'jdbc:mysql://localhost:3306/story', | 'connector.table' = 'story', | 'connector.username' = 'root', | 'connector.password' = 'root' |)""".stripMargin
    
    
        tableEnv.sqlUpdate(createTableSql)
        val table: Table = tableEnv.sqlQuery("select id, title from story")
    
        table.printSchema()
    
        table.toAppendStream[(Long,String)].print("sql")
    
        env.execute("table api test")
      }
    
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，85人围观）

还没有评论，来说两句吧...

相关阅读

相关 flink读取kafka数据

前言在实际生产环境中，经常需要使用flink读取外部的数据源作为数据的输入流，其中kafka就是重要的实时数据源，flink可以通过消费kafka指定的topic数据达

不念不忘少年蓝@/ 2023年10月02日 17:39/ 0 赞/ 23 阅读

相关 Flink去重第二弹：SQL方式

点击上方蓝字关注~ 在[Flink去重第一弹:MapState去重][Flink_MapState]中介绍了使用编码方式完成去重，但是这种方式开发周期比较长，我们可能需要

怼烎@/ 2023年06月25日 07:45/ 0 赞/ 7 阅读

相关 flink 1.10 source方式读取mysql

class mysql_source extends RichSourceFunction[(Long, String, Long)] { private

小鱼儿/ 2022年12月19日 08:51/ 0 赞/ 103 阅读

相关 flink 1.10 sql 方式读取 mysql

ddl 方式 package com.jq.wc import org.apache.flink.streaming.api.scala._

╰+哭是因爲堅強的太久メ/ 2022年12月19日 01:22/ 0 赞/ 86 阅读

相关 Flink通过读取sql语句，执行代码

参考：[http://wuchong.me/blog/2019/09/02/flink-sql-1-9-read-from-kafka-write-into-mysql/][h

落日映苍穹つ/ 2022年12月13日 01:38/ 0 赞/ 172 阅读

相关 flink 1.10 Sql方式读取kafka

ddl模式 import org.apache.flink.streaming.api.scala._ import org.apache.flink.t

Love The Way You Lie/ 2022年11月22日 12:59/ 0 赞/ 156 阅读

相关使用Flink SQL CDC读取动态配置表

Flink SQL CDC 介绍 CDC 全称是`Change Data Capture` ，它是一个比较广义的概念，只要能`捕获变更的数据`，我们都可以称为 CDC 。

Love The Way You Lie/ 2022年11月09日 14:29/ 0 赞/ 803 阅读

相关 flink重复读取mysql_flink读写MySQL的两种方式

2020-05-22 12:09:48,198 WARN org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler

- 日理万妓/ 2022年10月26日 12:58/ 0 赞/ 34 阅读

相关【Flink】Flink SQL 读取 CSV 文件

文章目录 3.7 source 3.7 连续查询 3.8 Sink Tables 3.8.1 案例1

亦凉/ 2022年09月11日 05:18/ 0 赞/ 287 阅读

相关【Flink入门】Flink自定义Source读取MySQL数据

在前一篇博客中 [【Flink入门】Flink读取Kafka数据Demo][Flink_Flink_Kafka_Demo] 已经简单介绍了Flink读取Kafka数据并通过De

╰半夏微凉°/ 2021年09月25日 04:44/ 0 赞/ 891 阅读