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