Hadoop Streaming

參考鏈接:https://zhuanlan.zhihu.com/p/34903460
https://blog.csdn.net/frankie110/article/details/38274965
https://www.cnblogs.com/duking1991/p/6077110.html

hadoop常用的參數(shù)總結(jié)

-D mapred.job.priority="NORMAL"

任務(wù)的優(yōu)先級(jí) `VERY_HIGH  HIGH    NORMAL     LOW    VERY_LOW`
-D mapred.job.name=jobname 指定作業(yè)名稱(chēng)
-D mapred.map.tasks=numofmap 每個(gè)Job運(yùn)行map task的數(shù)量
-D mapred.reduce.tasks=numofreduce 每個(gè)Job運(yùn)行reduce task的數(shù)量,
如果指定為 0俏站,則意味著提交了一個(gè)map only的任務(wù)

分隔符參數(shù)設(shè)置

hadoop中的map-reduce是處理<key,value>這樣的鍵值對(duì)腋颠,故指定<key,value>的分割符等參數(shù)可以分成三類(lèi):

1、map輸出時(shí)分割符

2邪财、分桶時(shí)的分隔符

3、reduce輸出時(shí)的分割符

1. map輸出時(shí)分割符 

參數(shù): stream.map.output.field.separator 

作用: 指定map輸出時(shí)的分割符 

stream.num.map.output.key.fields 

指定輸出按照分隔符切割后,key所占有的列數(shù) 

(設(shè)置map程序分隔符的位置识埋,該位置之前的部分作為key,之后的部分作為value)

Example

input數(shù)據(jù):  2,2,c,c,c,c 

參數(shù)配置: 

-mapper "cat" # map 為分布式的cat命令 

-reducer ""  #reduce為空 / 

-jobconf stream.map.output.field.separator=','  / 

-jobconf stream.num.map.output.key.fields=2 / 

即按照','逗號(hào)分隔后零渐,取前2列作為key 

output數(shù)據(jù): 

2,2     c,c,c,c  #其中key為2,2  value為c,c,c,c 

2窒舟、分桶時(shí)的分隔符

map.output.key.field.separator 

指定map輸出<key,value>對(duì)之后,其中key內(nèi)部的分割符 

num.key.fields.for.partition 

指定分桶時(shí)诵盼,按照分隔符切割后惠豺,用于分桶key所占的列數(shù) 

Example

map的output數(shù)據(jù): 2,2     c,c,c,c 

參數(shù)配置: 
-jobconf map.output.key.field.separator=',' / 
-jobconf num.key.fields.for.partition='1'   / 
-partitioner org.apache.hadoop.mapred.lib.KeyFieldBasedPartitioner / 

output數(shù)據(jù): 

這樣用于partition分桶的key就為:2 

注意,這里分桶不應(yīng)該用默認(rèn)的HashPartitioner 
-D num.key.fields.for.partition 

指定分桶時(shí)风宁,key按照分隔符切割后洁墙,其中用于分桶key所占的列數(shù)(配合-partitionerorg.apache.hadoop.mapred.lib.KeyFieldBasedPartitioner 使用)
  1. reduce輸出時(shí)的分割符
這個(gè)與map類(lèi)似,分別用于reduce輸出時(shí)分隔符以及key占有的列數(shù) 

stream.reduce.output.field.separator 

stream.num.reduce.output.key.fields
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末戒财,一起剝皮案震驚了整個(gè)濱河市热监,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌饮寞,老刑警劉巖孝扛,帶你破解...
    沈念sama閱讀 219,427評(píng)論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場(chǎng)離奇詭異骂际,居然都是意外死亡疗琉,警方通過(guò)查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,551評(píng)論 3 395
  • 文/潘曉璐 我一進(jìn)店門(mén)歉铝,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)盈简,“玉大人,你說(shuō)我怎么就攤上這事太示∧停” “怎么了?”我有些...
    開(kāi)封第一講書(shū)人閱讀 165,747評(píng)論 0 356
  • 文/不壞的土叔 我叫張陵类缤,是天一觀的道長(zhǎng)臼勉。 經(jīng)常有香客問(wèn)我,道長(zhǎng)餐弱,這世上最難降的妖魔是什么宴霸? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 58,939評(píng)論 1 295
  • 正文 為了忘掉前任囱晴,我火速辦了婚禮,結(jié)果婚禮上瓢谢,老公的妹妹穿的比我還像新娘畸写。我一直安慰自己,他們只是感情好氓扛,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,955評(píng)論 6 392
  • 文/花漫 我一把揭開(kāi)白布枯芬。 她就那樣靜靜地躺著,像睡著了一般采郎。 火紅的嫁衣襯著肌膚如雪千所。 梳的紋絲不亂的頭發(fā)上,一...
    開(kāi)封第一講書(shū)人閱讀 51,737評(píng)論 1 305
  • 那天蒜埋,我揣著相機(jī)與錄音淫痰,去河邊找鬼。 笑死理茎,一個(gè)胖子當(dāng)著我的面吹牛黑界,可吹牛的內(nèi)容都是我干的管嬉。 我是一名探鬼主播皂林,決...
    沈念sama閱讀 40,448評(píng)論 3 420
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼蚯撩!你這毒婦竟也來(lái)了础倍?” 一聲冷哼從身側(cè)響起,我...
    開(kāi)封第一講書(shū)人閱讀 39,352評(píng)論 0 276
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤胎挎,失蹤者是張志新(化名)和其女友劉穎沟启,沒(méi)想到半個(gè)月后,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體犹菇,經(jīng)...
    沈念sama閱讀 45,834評(píng)論 1 317
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡德迹,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,992評(píng)論 3 338
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了揭芍。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片胳搞。...
    茶點(diǎn)故事閱讀 40,133評(píng)論 1 351
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖称杨,靈堂內(nèi)的尸體忽然破棺而出肌毅,到底是詐尸還是另有隱情,我是刑警寧澤姑原,帶...
    沈念sama閱讀 35,815評(píng)論 5 346
  • 正文 年R本政府宣布悬而,位于F島的核電站,受9級(jí)特大地震影響锭汛,放射性物質(zhì)發(fā)生泄漏笨奠。R本人自食惡果不足惜袭蝗,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,477評(píng)論 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望般婆。 院中可真熱鬧呻袭,春花似錦、人聲如沸腺兴。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 32,022評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)页响。三九已至篓足,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間闰蚕,已是汗流浹背栈拖。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 33,147評(píng)論 1 272
  • 我被黑心中介騙來(lái)泰國(guó)打工, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留没陡,地道東北人涩哟。 一個(gè)月前我還...
    沈念sama閱讀 48,398評(píng)論 3 373
  • 正文 我出身青樓,卻偏偏與公主長(zhǎng)得像盼玄,于是被迫代替她去往敵國(guó)和親贴彼。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,077評(píng)論 2 355

推薦閱讀更多精彩內(nèi)容