@焉知非魚 趕緊的吧
用 parquet 數(shù)據(jù)模擬實(shí)時(shí)數(shù)據(jù)流用 parquet 數(shù)據(jù)模擬實(shí)時(shí)數(shù)據(jù)流 再將 JSON 數(shù)據(jù)逐行發(fā)到 Kafka 的不同 topic：
發(fā)簡(jiǎn)信
IP屬地：安徽
-
-
@碼仙丶 地址呢？
zookeeper的watcher
利用zk的watcher功能實(shí)時(shí)監(jiān)控zk節(jié)點(diǎn)的變化，可以利用這個(gè)功能做報(bào)警、監(jiān)控，例如監(jiān)控kafka的broker，otter的node等，如果有節(jié)點(diǎn)掛掉，立時(shí)通知
-
@焉知非魚 代碼呢？又吝嗇了
用 parquet 數(shù)據(jù)模擬實(shí)時(shí)數(shù)據(jù)流
用 parquet 數(shù)據(jù)模擬實(shí)時(shí)數(shù)據(jù)流 再將 JSON 數(shù)據(jù)逐行發(fā)到 Kafka 的不同 topic：
-
碼仙仙：
pom文件可以發(fā)一下嗎？zookeeper的watcher
利用zk的watcher功能實(shí)時(shí)監(jiān)控zk節(jié)點(diǎn)的變化，可以利用這個(gè)功能做報(bào)警、監(jiān)控，例如監(jiān)控kafka的broker，otter的node等，如果有節(jié)點(diǎn)掛掉，立時(shí)通知
-
zookeeper的watcher
利用zk的watcher功能實(shí)時(shí)監(jiān)控zk節(jié)點(diǎn)的變化，可以利用這個(gè)功能做報(bào)警、監(jiān)控，例如監(jiān)控kafka的broker，otter的node等，如果有節(jié)點(diǎn)掛掉，立時(shí)通知
-
一天天求帶；球呢？
HBase新版本Java API
HBase新版本Java API 之前沒(méi)有碼全，這次增刪改查全乎了，網(wǎng)上有很多例子，自己根據(jù)實(shí)際在用的收集總結(jié)了一下 導(dǎo)入的包 初始化連接對(duì)象 創(chuàng)建表、刪除表 向表中單行pu...
-
好的碼仙仙
HBase新版本Java API
HBase新版本Java API 之前沒(méi)有碼全，這次增刪改查全乎了，網(wǎng)上有很多例子，自己根據(jù)實(shí)際在用的收集總結(jié)了一下 導(dǎo)入的包 初始化連接對(duì)象 創(chuàng)建表、刪除表 向表中單行pu...
-
sparkStreaming拉取kafka010的bug
目前kafka版本中，很多公司在用kafka010，但是在用sparkstreaming去消費(fèi)kafka時(shí)，很多人都會(huì)碰到一個(gè)錯(cuò)誤 解決步驟 根據(jù)報(bào)錯(cuò)信息 可以看出是在這里跑...
-
需求是啥；為啥先parquet后json 呢？
用 parquet 數(shù)據(jù)模擬實(shí)時(shí)數(shù)據(jù)流
用 parquet 數(shù)據(jù)模擬實(shí)時(shí)數(shù)據(jù)流 再將 JSON 數(shù)據(jù)逐行發(fā)到 Kafka 的不同 topic：
-
用 parquet 數(shù)據(jù)模擬實(shí)時(shí)數(shù)據(jù)流
用 parquet 數(shù)據(jù)模擬實(shí)時(shí)數(shù)據(jù)流 再將 JSON 數(shù)據(jù)逐行發(fā)到 Kafka 的不同 topic：
-
十分鐘理解廣告系統(tǒng)什么是廣告系統(tǒng) 廣告是以“把合適的內(nèi)容推送給合適的受眾”為目的的商業(yè)交易過(guò)程，它同時(shí)為三種人群服務(wù)：第一種是廣告主，即出錢購(gòu)買廣告的人，需要通過(guò)廣告獲取顧客；第二種是媒體，即...
-
請(qǐng)問(wèn)大神；你是哪個(gè)“龜”？
MySQL按條件刪除報(bào)錯(cuò)You can't specify target table 'xxx' for update in FROM clause
經(jīng)常使用mysql 的查詢功能，比較少使用刪除。最近在網(wǎng)上做了幾個(gè)sql題，有一個(gè)刪除的問(wèn)題，本以為挺簡(jiǎn)單，確報(bào)出如題目的錯(cuò)誤，在網(wǎng)上一搜索才發(fā)現(xiàn)了這個(gè)問(wèn)題。謹(jǐn)以此作為自己的...
-
MySQL按條件刪除報(bào)錯(cuò)You can't specify target table 'xxx' for update in FROM clause
經(jīng)常使用mysql 的查詢功能，比較少使用刪除。最近在網(wǎng)上做了幾個(gè)sql題，有一個(gè)刪除的問(wèn)題，本以為挺簡(jiǎn)單，確報(bào)出如題目的錯(cuò)誤，在網(wǎng)上一搜索才發(fā)現(xiàn)了這個(gè)問(wèn)題。謹(jǐn)以此作為自己的...
-
似不似撒；問(wèn)??這個(gè)大神啊
Python獲取Hive數(shù)據(jù)計(jì)算相關(guān)性系數(shù)
需求： 1.從hive 表中獲取數(shù)據(jù)。 2.計(jì)算各個(gè)指標(biāo)與主分析指標(biāo)間的相關(guān)系數(shù)。 3.將計(jì)算出來(lái)的相關(guān)系數(shù)，放入csv 文件，待使用。 首先，相關(guān)系數(shù)我們選擇了皮爾遜相關(guān)系...
-
-
使用 Spark 讀寫 HBase 數(shù)據(jù)
Use Spark to read and write HBase data 啟動(dòng) hbase 在 HBase 中準(zhǔn)備 sample 數(shù)據(jù) 1、運(yùn)行 HBase shell ...
-
這個(gè)是：先刪除再重建topic？還是刪除了以后無(wú)論topic是什么狀態(tài)也不用管了？
kafka刪除topic
刪除kafka topic及其數(shù)據(jù)，嚴(yán)格來(lái)說(shuō)并不是很難的操作。但是，往往給kafka 使用者帶來(lái)諸多問(wèn)題，發(fā)現(xiàn)都會(huì)偶然出現(xiàn)無(wú)法徹底刪除kafka的情況。前提：kafka必須配...
