开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 网格计算 > 查看源码
README.txt
资源名称：hadoop-0.20.0.tar.gz　[点击查看]
上传用户：quxuerui
上传日期：2018-01-08
资源大小：41811k
文件大小：2k
源码类别：

网格计算

开发平台：

Java

README.txt：源码内容
  1. *************************************************
  2. *** Input Files (Note: tab-separated columns) ***
  3. *************************************************
  4. [:~]$ cat datajoin/input/A
  5. A.a11   A.a12
  6. A.a21   A.a22
  7. B.a21   A.a32
  8. A.a31   A.a32
  9. B.a31   A.a32
  11. [:~]$ cat datajoin/input/B
  12. A.a11   B.a12
  13. A.a11   B.a13
  14. B.a11   B.a12
  15. B.a21   B.a22
  16. A.a31   B.a32
  17. B.a31   B.a32
  20. *****************************
  21. *** Invoke SampleDataJoin ***
  22. *****************************
  23. [:~]$ $HADOOP_HOME/bin/hadoop jar hadoop-datajoin-examples.jar org.apache.hadoop.contrib.utils.join.DataJoinJob datajoin/input datajoin/output Text 1 org.apache.hadoop.contrib.utils.join.SampleDataJoinMapper org.apache.hadoop.contrib.utils.join.SampleDataJoinReducer org.apache.hadoop.contrib.utils.join.SampleTaggedMapOutput Text
  24. Using TextInputFormat: Text
  25. Using TextOutputFormat: Text
  26. 07/06/01 19:58:23 INFO mapred.FileInputFormat: Total input paths to process : 2
  27. Job job_kkzk08 is submitted
  28. Job job_kkzk08 is still running.
  29. 07/06/01 19:58:24 INFO mapred.LocalJobRunner: collectedCount    5
  30. totalCount      5
  32. 07/06/01 19:58:24 INFO mapred.LocalJobRunner: collectedCount    6
  33. totalCount      6
  35. 07/06/01 19:58:24 INFO datajoin.job: key: A.a11 this.largestNumOfValues: 3
  36. 07/06/01 19:58:24 INFO mapred.LocalJobRunner: actuallyCollectedCount    5
  37. collectedCount  7
  38. groupCount      6
  39.  > reduce
  42. *******************
  43. *** Output File ***
  44. *******************
  45. [:~]$ cat datajoin/output/part-00000  
  46. A.a11   A.a12   B.a12
  47. A.a11   A.a12   B.a13
  48. A.a31   A.a32   B.a32
  49. B.a21   A.a32   B.a22
  50. B.a31   A.a32   B.a32