99999久久久久久亚洲,欧美人与禽猛交狂配,高清日韩av在线影院,一个人在线高清免费观看,啦啦啦在线视频免费观看www

熱線電話:13121318867

登錄
首頁精彩閱讀常見的七種Hadoop和Spark項目案例
常見的七種Hadoop和Spark項目案例
2018-06-28
收藏

常見的七種Hadoop和Spark項目案例

如果你的Hadoop項目將有新的突破,那么它必定與下邊介紹的七種常見項目很相像。

有一句古老的格言是這樣說的,如果你向某人提供你的全部支持和金融支持去做一些不同的和創(chuàng)新的事情,他們最終卻會做別人正在做的事情。如比較火爆的Hadoop、Spark和Storm,每個人都認為他們正在做一些與這些新的大數(shù)據(jù)技術(shù)相關的事情,但它不需要很長的時間遇到相同的模式。具體的實施可能有所不同,但根據(jù)我的經(jīng)驗,它們是最常見的七種項目。

項目一:數(shù)據(jù)整合

稱之為“企業(yè)級數(shù)據(jù)中心”或“數(shù)據(jù)湖”,這個想法是你有不同的數(shù)據(jù)源,你想對它們進行數(shù)據(jù)分析。這類項目包括從所有來源獲得數(shù)據(jù)源(實時或批處理)并且把它們存儲在hadoop中。有時,這是成為一個“數(shù)據(jù)驅(qū)動的公司”的第一步;有時,或許你僅僅需要一份漂亮的報告?!捌髽I(yè)級數(shù)據(jù)中心”通常由HDFS文件系統(tǒng)和HIVE或IMPALA中的表組成。未來,HBase和Phoenix在大數(shù)據(jù)整合方面將大展拳腳,打開一個新的局面,創(chuàng)建出全新的數(shù)據(jù)美麗新世界。

銷售人員喜歡說“讀模式”,但事實上,要取得成功,你必須清楚的了解自己的用例將是什么(Hive模式不會看起來與你在企業(yè)數(shù)據(jù)倉庫中所做的不一樣)。真實的原因是一個數(shù)據(jù)湖比Teradata和Netezza公司有更強的水平擴展性和低得多的成本。許多人在做前端分析時使用Tableau和Excel。許多復雜的公司以“數(shù)據(jù)科學家”用Zeppelin或IPython筆記本作為前端。

項目二:專業(yè)分析

許多數(shù)據(jù)整合項目實際上是從你特殊的需求和某一數(shù)據(jù)集系統(tǒng)的分析開始的。這些往往是令人難以置信的特定領域,如在銀行領域的流動性風險/蒙特卡羅模擬分析。在過去,這種專業(yè)的分析依賴于過時的,專有的軟件包,無法擴大數(shù)據(jù)的規(guī)模經(jīng)常遭受一個有限的功能集(大部分是因為軟件廠商不可能像專業(yè)機構(gòu)那樣了解的那么多)。

Hadoop和Spark的世界,看看這些系統(tǒng)大致相同的數(shù)據(jù)整合系統(tǒng),但往往有更多的HBase,定制非SQL代碼,和更少的數(shù)據(jù)來源(如果不是唯一的)。他們越來越多地以Spark為基礎。

項目三:Hadoop作為一種服務

在“專業(yè)分析”項目的任何大型組織(諷刺的是,一個或兩個“數(shù)據(jù)整理”項目)他們會不可避免地開始感覺“快樂”(即,疼痛)管理幾個不同配置的Hadoop集群,有時從不同的供應商。接下來,他們會說,“也許我們應該整合這些資源池,”而不是大部分時間讓大部分節(jié)點處于資源閑置狀態(tài)。它們應該組成云計算,但許多公司經(jīng)常會因為安全的原因(內(nèi)部政治和工作保護)不能或不會。這通常意味著很多Docker容器包。

我沒有使用它,但最近Bluedata(藍色數(shù)據(jù)國際中心)似乎有一個解決方案,這也會吸引小企業(yè)缺乏足夠的資金來部署Hadoop作為一種服務。

項目四:流分析

很多人會把這個“流”,但流分析是不同的,從設備流。通常,流分析是一個組織在批處理中的實時版本。以反洗錢和欺詐檢測:為什么不在交易的基礎上,抓住它發(fā)生而不是在一個周期結(jié)束?同樣的庫存管理或其他任何。

在某些情況下,這是一種新的類型的交易系統(tǒng),分析數(shù)據(jù)位的位,因為你將它并聯(lián)到一個分析系統(tǒng)中。這些系統(tǒng)證明自己如Spark或Storm與Hbase作為常用的數(shù)據(jù)存儲。請注意,流分析并不能取代所有形式的分析,對某些你從未考慮過的事情而言,你仍然希望分析歷史趨勢或看過去的數(shù)據(jù)。

項目五:復雜事件處理

在這里,我們談論的是亞秒級的實時事件處理。雖然還沒有足夠快的超低延遲(皮秒或納秒)的應用,如高端的交易系統(tǒng),你可以期待毫秒響應時間。例子包括對事物或事件的互聯(lián)網(wǎng)電信運營商處理的呼叫數(shù)據(jù)記錄的實時評價。有時,你會看到這樣的系統(tǒng)使用Spark和HBase——但他們一般落在他們的臉上,必須轉(zhuǎn)換成Storm,這是基于由LMAX交易所開發(fā)的干擾模式。

在過去,這樣的系統(tǒng)已經(jīng)基于定制的消息或高性能,從貨架上,客戶端-服務器消息產(chǎn)品-但今天的數(shù)據(jù)量太多了。我還沒有使用它,但Apex項目看起來很有前途,聲稱要比Storm快。

項目六:ETL

有時你想捕捉流數(shù)據(jù)并把它們存儲起來。這些項目通常與1號或2號重合,但增加了各自的范圍和特點。(有些人認為他們是4號或5號,但他們實際上是在向磁盤傾倒和分析數(shù)據(jù)。),這些幾乎都是Kafka和Storm項目。Spark也使用,但沒有理由,因為你不需要在內(nèi)存分析。

項目七:更換或增加SAS

SAS是精細,是好的但SAS也很貴,我們不需要為你的數(shù)據(jù)科學家和分析師買存儲你就可以“玩”數(shù)據(jù)。此外,除SAS可以做或產(chǎn)生漂亮的圖形分析外,你還可以做一些不同的事情。這是你的“數(shù)據(jù)湖”。這里是IPython筆記本(現(xiàn)在)和Zeppelin(以后)。我們用SAS存儲結(jié)果。

當我每天看到其他不同類型的Hadoop,Spark,或Storm項目,這些都是正常的。如果你使用Hadoop,你可能了解它們。幾年前我已經(jīng)實施了這些項目中的部分案例,使用的是其它技術(shù)。

如果你是一個老前輩太害怕“大”或“做”大數(shù)據(jù)Hadoop,不要擔心。事情越變越多,但本質(zhì)保持不變。你會發(fā)現(xiàn)很多相似之處的東西你用來部署和時髦的技術(shù)都是圍繞Hadooposphere旋轉(zhuǎn)的。


數(shù)據(jù)分析咨詢請掃描二維碼

若不方便掃碼,搜微信號:CDAshujufenxi

數(shù)據(jù)分析師資訊
更多

OK
客服在線
立即咨詢
客服在線
立即咨詢
') } function initGt() { var handler = function (captchaObj) { captchaObj.appendTo('#captcha'); captchaObj.onReady(function () { $("#wait").hide(); }).onSuccess(function(){ $('.getcheckcode').removeClass('dis'); $('.getcheckcode').trigger('click'); }); window.captchaObj = captchaObj; }; $('#captcha').show(); $.ajax({ url: "/login/gtstart?t=" + (new Date()).getTime(), // 加隨機數(shù)防止緩存 type: "get", dataType: "json", success: function (data) { $('#text').hide(); $('#wait').show(); // 調(diào)用 initGeetest 進行初始化 // 參數(shù)1:配置參數(shù) // 參數(shù)2:回調(diào),回調(diào)的第一個參數(shù)驗證碼對象,之后可以使用它調(diào)用相應的接口 initGeetest({ // 以下 4 個配置參數(shù)為必須,不能缺少 gt: data.gt, challenge: data.challenge, offline: !data.success, // 表示用戶后臺檢測極驗服務器是否宕機 new_captcha: data.new_captcha, // 用于宕機時表示是新驗證碼的宕機 product: "float", // 產(chǎn)品形式,包括:float,popup width: "280px", https: true // 更多配置參數(shù)說明請參見:http://docs.geetest.com/install/client/web-front/ }, handler); } }); } function codeCutdown() { if(_wait == 0){ //倒計時完成 $(".getcheckcode").removeClass('dis').html("重新獲取"); }else{ $(".getcheckcode").addClass('dis').html("重新獲取("+_wait+"s)"); _wait--; setTimeout(function () { codeCutdown(); },1000); } } function inputValidate(ele,telInput) { var oInput = ele; var inputVal = oInput.val(); var oType = ele.attr('data-type'); var oEtag = $('#etag').val(); var oErr = oInput.closest('.form_box').next('.err_txt'); var empTxt = '請輸入'+oInput.attr('placeholder')+'!'; var errTxt = '請輸入正確的'+oInput.attr('placeholder')+'!'; var pattern; if(inputVal==""){ if(!telInput){ errFun(oErr,empTxt); } return false; }else { switch (oType){ case 'login_mobile': pattern = /^1[3456789]\d{9}$/; if(inputVal.length==11) { $.ajax({ url: '/login/checkmobile', type: "post", dataType: "json", data: { mobile: inputVal, etag: oEtag, page_ur: window.location.href, page_referer: document.referrer }, success: function (data) { } }); } break; case 'login_yzm': pattern = /^\d{6}$/; break; } if(oType=='login_mobile'){ } if(!!validateFun(pattern,inputVal)){ errFun(oErr,'') if(telInput){ $('.getcheckcode').removeClass('dis'); } }else { if(!telInput) { errFun(oErr, errTxt); }else { $('.getcheckcode').addClass('dis'); } return false; } } return true; } function errFun(obj,msg) { obj.html(msg); if(msg==''){ $('.login_submit').removeClass('dis'); }else { $('.login_submit').addClass('dis'); } } function validateFun(pat,val) { return pat.test(val); }