發(fā)簡(jiǎn)信
IP屬地：陜西
-
Zookeeper+Kafka集群部署
Zookeeper+Kafka集群部署 kafka: kafka_2.11-2.2.0.tar.gzzookeeper: zookeeper-3...
-
Hive時(shí)間轉(zhuǎn)換
Hive時(shí)間轉(zhuǎn)換 用到hive時(shí)間轉(zhuǎn)換總結(jié)如下: 轉(zhuǎn)換成小時(shí) req_time是 "2016-11-29 17:47:59"要轉(zhuǎn)換成小時(shí)"201...
-
Flink實(shí)現(xiàn)Kafka到Mysql的Exactly-OnceFlink實(shí)現(xiàn)Kafka到Mysql的Exactly-Once 背景 最近項(xiàng)目中使用Flink消費(fèi)kafka消息，并將消費(fèi)的消息存儲(chǔ)到mysql...
-
Blink First Time & Flink-sqlBlink First Time & Flink-sql 背景 blink開源，目前在https://github.com/apache/fli...
-
python訪問hdfs(namenode是HA)python訪問hdfs(namenode是HA) 背景 本文記錄用python訪問hdfs，hdfs有兩個(gè)namenode HA模式。主要有h...
-
python字符串如何判斷相等
python字符串如何判斷相等 1.is來判斷 2.id 和 in 看到用in可以判斷兩個(gè)字符串相等 參考：https://blog.csdn....
-
Druid-Tranquility中查詢粒度設(shè)置為5分鐘Druid-Tranquility中查詢粒度設(shè)置為5分鐘 背景 我們知道可以通過tranquility從kafka讀取數(shù)據(jù)寫入druid做聚合，...
-
Flink狀態(tài)（state）管理在代碼里配置checkpointcheckPoint簡(jiǎn)介 為了保證state的容錯(cuò)性，F(xiàn)link需要對(duì)state進(jìn)行checkpoint。 Checkpoint是Flink實(shí)現(xiàn)...
-
Flink JobManager HA高可用Flink JobManager HA高可用 概述 本文主要講解下Flink standalone下JobManager的HA高可用和Flink...
個(gè)人介紹
和一些做技術(shù)的朋友建了一個(gè)大數(shù)據(jù)、機(jī)器學(xué)習(xí)的QQ群（有BAT的大佬），歡迎加入、交流、學(xué)習(xí)！
QQ群：432600958
QQ群：432600958