240 发简信
IP属地:四川
  • 120
    Flink 获取kafka数据 sinkHbase

    1. 处理流程: 2.Hbase 建表 3. kafak 使用命令 4. 项目结构: 主要的类: HbaseSink 类 4.1 pom 文件: 4.2 User 类 4.3...

  • 120
    Flink详解系列之四--时间

    在流处理场景中,处理的是持续到达且可能是无穷的事件流,时间在这样的应用中是最核心的要素。Flink定义了三种时间类型: 事件时间(Event Time) 事件时间是数据流中事...