今天就跟大家聊聊有關(guān)MapReduce引擎如何實現(xiàn)，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

順德網(wǎng)站建設(shè)公司創(chuàng)新互聯(lián)建站,順德網(wǎng)站設(shè)計制作，有大型網(wǎng)站制作公司豐富經(jīng)驗。已為順德數(shù)千家提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\外貿(mào)網(wǎng)站制作要多少錢，請找那個售后服務(wù)好的順德做網(wǎng)站的公司定做！

MapReduce引擎怎么實現(xiàn)

使用例子見下，只需要import一個名即可。

#!/usr/bin/env python

import mincemeat

data = ["Humpty Dumpty sat on a wall",

"Humpty Dumpty had a great fall",

"All the King's horses and all the King's men",

"Couldn't put Humpty together again",

]

def mapfn(k, v):

for w in v.split():

yield w, 1

def reducefn(k, vs):

MapReduce引擎怎么實現(xiàn)

result = 0

for v in vs:

result += v

return result

s = mincemeat.Server()

# The data source can be any dictionary-like object

s.datasource = dict(enumerate(data))

s.mapfn = mapfn

s.reducefn = reducefn

results = s.run_server(password="changeme")

print results

然后將mincemeat.py 和example.py 放在同一個目錄下，執(zhí)行example.py

python example.py

這時程序會掛起一個daemon

然后另開一終端運行：

python mincemeat.py -p changeme localhost

就會看到剛才的daemon打印出了MapReduce結(jié)果并退出了。

{‘a(chǎn)’: 2, ‘on’: 1, ‘great’: 1, ‘Humpty’: 3, ‘a(chǎn)gain’: 1, ‘wall’: 1, ‘Dumpty’: 2, ‘men’: 1, ‘had’: 1, ‘a(chǎn)ll’: 1, ‘together’: 1, “King’s”: 2, ‘horses’: 1, ‘All’: 1, “Couldn’t”: 1, ‘fall’: 1, ‘a(chǎn)nd’: 1, ‘the’: 2, ‘put’: 1, ’sat’: 1}

看完上述內(nèi)容，你們對MapReduce引擎如何實現(xiàn)有進(jìn)一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。

當(dāng)前名稱：MapReduce引擎如何實現(xiàn)
地址分享：http://chinadenli.net/article38/giojsp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設(shè)計公司、企業(yè)建站、網(wǎng)站導(dǎo)航、網(wǎng)站建設(shè)、手機(jī)網(wǎng)站建設(shè)、App設(shè)計

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)