网站首页 站内搜索

搜索结果

查询Tags标签: updateStmt,共有 1条记录
  • Flink写入数据到MySQL案例

    案例准备: 1、启动MySQL,在mysql中创建数据库flinkdb,并创建表sensor_temp CREATE TABLE sensor_temp (id varchar(32),temp double ) 代码实现: def main(args: Array[String]): Unit = {val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExec…

    2022/2/22 19:23:57 人评论 次浏览
扫一扫关注最新编程教程