java Git 二叉树排序 Apache Pivot教程 matrix safari Material UI Avalon vue注册组件 java后台框架 时间戳java python抛异常 java编程入门 java8的新特性 java中的继承 java写入txt java可变参数 java接口实例 linuxtar命令 flash相册制作 微信助力软件 java疯狂讲义 美国地址生成器 c语言指数函数 kafka权威指南 证书小精灵 脚本网站 怎么看淘龄 java表白代码 hzfs 苹果手机常去地点 mysql数据库恢复 cdr透明度怎么调 fabfilter 祸星龙 超级好友 c语言贪吃蛇 c语言小程序 imacros 叉叉修改器
当前位置: 首页 > 学习教程  > 编程语言

Flink系列-实时数仓之Flink实时写入ClickHouse并实时大屏Tableau

2020/11/24 10:35:42 文章标签: 测试文章如有侵权请发送至邮箱809451989@qq.com投诉后文章立即删除

整体架构图 工具 Flink 1.11.2 Scala 2.11 Tableau 2020.2 一、模拟发送数据 新建一个类KafkaProducer用来模拟产生消费数据,代码如下: package TopNitemsimport java.text.SimpleDateFormat import java.time.{LocalTime, ZonedDateTime} import java.time.format.Date…

整体架构图

工具

Flink 1.11.2

Scala 2.11

Tableau 2020.2

一、模拟发送数据

新建一个类KafkaProducer用来模拟产生消费数据,代码如下:

package TopNitems

import java.text.SimpleDateFormat
import java.time.{LocalTime, ZonedDateTime}
import java.time.format.DateTimeFormatter
import java.util.{Date, Locale, Properties}

import scala.io.Source
import org.apache.kafka.clients.producer.{KafkaProducer, ProducerRecord}

import Array._
import scala.util.Random.shuffle


object KafkaProducers {
  def main(args: Array[String]): Unit = {
    SendtoKafka("test")
  }
  def SendtoKafka(topic:String): Unit = {
    val pro=new Properties()
    pro.put("bootstrap.servers", "192.168.226.10:9092")
    pro.setProperty("key.s

本文链接: http://www.dtmao.cc/news_show_400279.shtml

附件下载

相关教程

    暂无相关的数据...

共有条评论 网友评论

验证码: 看不清楚?