240 发简信
IP属地:内蒙古自治区
  • 博客中的一些配置

    Hadoop集群配置 ip地址如下 软件版本 core-default.xmlhdfs-default.xmlmapred-default.xm...

  • Flink Redis Sink 自定义

    背景 Flink 默认的 RedisMapper 不能设置key的过期时间。 依赖 SinkFunction & RichSinkFuncti...

  • Resize,w 360,h 240
    Flink Redis Sink 基本用法

    简介 flink提供了专门操作redis的Redis Sink 依赖 类 Redis Sink 提供用于向Redis发送数据的接口的类。接收器可...

  • Resize,w 360,h 240
    Flink WaterMark 详解

    背景 实时计算中,数据时间比较敏感。有eventTime和processTime区分,一般来说eventTime是从原始的消息中提取过来的,pr...

  • Hadoop HDFS 的 I/O 流操作

    HDFS 文件上传 HDFS 文件下载 定位文件读取 文件合并

  • Resize,w 360,h 240
    Hadoop HDFS 数据流

    HDFS 写数据流程 客户端通过Distributed FileSystem模块向NameNode请求上传文件,NameNode检查目 标文件是...