flink 1.10 sql 方式读取 mysql

╰+哭是因爲堅強的太久メ 2022-12-19 01:22 75阅读 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 条评论，75人围观）

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

相关阅读

相关 Flink SQL的打印输出的几种方式

打广告！！！！！！！！！！！！！！！！！！！！！！！！！：先跟鸡哥打个广告，博客地址: [https://me.csdn.net/weixin\_47482194][ht

川长思鸟来/ 2023年03月01日 09:49/ 0 赞/ 1101 阅读

相关 flink 1.10 source方式读取mysql

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

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

相关 flink 1.10 sql 方式读取 mysql

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

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

相关 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 赞/ 167 阅读

相关 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 赞/ 144 阅读

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

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

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

相关 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 赞/ 20 阅读

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

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

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

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

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

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

相关【Flink入门】Flink读取Kafka数据Demo

flink算子操作主要分为三大部分：source(数据读取)、transform(数据处理)、sink(数据输出)，这篇博客简单聊聊flink读取kafka数据在控制台打印的D

超、凢脫俗/ 2021年09月25日 04:40/ 0 赞/ 629 阅读