發(fā)簡信
IP屬地：內(nèi)蒙古自治區(qū)
-
博客中的一些配置
Hadoop集群配置 ip地址如下 軟件版本 core-default.xmlhdfs-default.xmlmapred-default.xm...
-
Flink Redis Sink 自定義
背景 Flink 默認(rèn)的 RedisMapper 不能設(shè)置key的過期時間撩扒。 依賴 SinkFunction & RichSinkFuncti...
-
Flink Redis Sink 基本用法
簡介 flink提供了專門操作redis的Redis Sink 依賴 類 Redis Sink 提供用于向Redis發(fā)送數(shù)據(jù)的接口的類似扔。接收器可...
-
Flink WaterMark 詳解背景 實(shí)時計(jì)算中，數(shù)據(jù)時間比較敏感搓谆。有eventTime和processTime區(qū)分炒辉，一般來說eventTime是從原始的消息中提取過來的，pr...
-
Hadoop HDFS 的 I/O 流操作
HDFS 文件上傳 HDFS 文件下載 定位文件讀取 文件合并
-
Hadoop HDFS 數(shù)據(jù)流HDFS 寫數(shù)據(jù)流程 客戶端通過Distributed FileSystem模塊向NameNode請求上傳文件泉手，NameNode檢查目 標(biāo)文件是...