Pigæ¯ä¸ç§ç¼ç¨è¯è¨ï¼å®ç®åäºHadoop常è§çå·¥ä½ä»»å¡ãPigå¯å è½½æ°æ®ã表达转æ¢æ°æ®ä»¥ååå¨æç»ç»æãPigå
ç½®çæä½ä½¿å¾åç»æåæ°æ®åå¾ææä¹ï¼å¦æ¥å¿æ件ï¼ãåæ¶Pigå¯æ©å±ä½¿ç¨Javaä¸æ·»å çèªå®ä¹æ°æ®ç±»å并æ¯ææ°æ®è½¬æ¢ã
Hiveå¨Hadoopä¸æ®æ¼æ°æ®ä»åºçè§è²ãHiveæ·»å æ°æ®çç»æå¨HDFSï¼hive superimposes structure on data in HDFSï¼ï¼å¹¶å
许使ç¨ç±»ä¼¼äºSQLè¯æ³è¿è¡æ°æ®æ¥è¯¢ãä¸Pigä¸æ ·ï¼Hiveçæ ¸å¿åè½æ¯å¯æ©å±çã
Hiveæ´éåäºæ°æ®ä»åºçä»»å¡ï¼Hive主è¦ç¨äºéæçç»æ以åéè¦ç»å¸¸åæçå·¥ä½ãHiveä¸SQLç¸ä¼¼ä¿ä½¿å
¶æ为Hadoopä¸å
¶ä»BIå·¥å
·ç»åççæ³äº¤éãPigèµäºå¼å人åå¨å¤§æ°æ®éé¢åæ´å¤ççµæ´»æ§ï¼å¹¶å
许å¼åç®æ´çèæ¬ç¨äºè½¬æ¢æ°æ®æµä»¥ä¾¿åµå
¥å°è¾å¤§çåºç¨ç¨åºãPigç¸æ¯Hiveç¸å¯¹è½»éï¼å®ä¸»è¦çä¼å¿æ¯ç¸æ¯äºç´æ¥ä½¿ç¨Hadoop Java APIså¯å¤§å¹
åå代ç éã
æ¬è´¨ä¸è¯´è¯´Pigä¸Hiveã
ç»è¿Pig Latinç转æ¢ååæäºä¸éMapReduceçä½ä¸ï¼éè¿MapReduceå¤ä¸ªçº¿ç¨ï¼è¿ç¨æè
ç¬ç«ç³»ç»å¹¶è¡æ§è¡å¤ççç»æéè¿è¡åç±»åå½çº³ãMap() å Reduce() 两个å½æ°ä¼å¹¶è¡è¿è¡ï¼å³ä½¿ä¸æ¯å¨åä¸çç³»ç»çåä¸æ¶å»ä¹å¨åæ¶è¿è¡ä¸å¥ä»»å¡ï¼å½ææçå¤çé½å®æä¹åï¼ç»æå°è¢«æåºï¼æ ¼å¼åï¼å¹¶ä¸ä¿åå°ä¸ä¸ªæ件ãPigå©ç¨MapReduceå°è®¡ç®åæ两个é¶æ®µï¼ç¬¬ä¸ä¸ªé¶æ®µå解æ为å°å并ä¸åå¸å°æ¯ä¸ä¸ªåå¨æ°æ®çèç¹ä¸è¿è¡æ§è¡ï¼å¯¹è®¡ç®çååè¿è¡åæ£ï¼ç¬¬äºä¸ªé¶æ®µèå第ä¸ä¸ªé¶æ®µæ§è¡çè¿äºç»æï¼è¿æ ·å¯ä»¥è¾¾å°é常é«çååéï¼éè¿ä¸å¤ç代ç åå·¥ä½éå°±è½å¤é©±å¨ä¸åå°æºå¨å¹¶è¡è®¡ç®ï¼å
åçå©ç¨è®¡ç®æºçèµæºï¼ææ¶è¿è¡ä¸çç¶é¢ã
ä¹å°±æ¯è¯´ï¼Pigæ大çä½ç¨å°±æ¯å¯¹mapreduceç®æ³(æ¡æ¶)å®ç°äºä¸å¥shellèæ¬ ï¼ç±»ä¼¼æ们é常çæçSQLè¯å¥ï¼å¨Pigä¸ç§°ä¹ä¸ºPig Latinï¼å¨è¿å¥èæ¬ä¸æ们å¯ä»¥å¯¹å è½½åºæ¥çæ°æ®è¿è¡æåºãè¿æ»¤ãæ±åãåç»(group by)ãå
³è(Joining)ï¼Pigä¹å¯ä»¥ç±ç¨æ·èªå®ä¹ä¸äºå½æ°å¯¹æ°æ®éè¿è¡æä½ï¼ä¹å°±æ¯ä¼ 说ä¸çUDF(user-defined functions)ã
ç»è®ºæ§çé
读æè§æ¯ï¼Pigç¨æ¥åä¸äºå³æ¶èæ¬å§ï¼æ¯å¦é¢å¯¼é®ä½ è¦ä»½æ°æ®ï¼å个å°æ¶è¦åºæ¥ä¹ç±»ï¼Hiveåï¼å°±æ¯ä¸ä¸ªäº§åç»çè¿æ¥ï¼é®è¿ä¸ªå¥åäº?äºæ¯ä½ Hiveä¸ä¸ï¼ä¸ä¸ªç®æ´çç±»SQLè¯å¥...Doneï¼
温馨提示:答案为网友推荐,仅供参考