codahale / hadoop-streaming fork watch download tarball
public
Description: Support libraries for writing Hadoop Streaming-compatible map/reduce tasks.
Clone URL: git://github.com/codahale/hadoop-streaming.git 
A bit of help and some changes.
codahale (author)
Mon Mar 24 15:18:00 -0700 2008
commit  a0e4230834a94d2bda9d672c0f1870d84babafe5
tree    8e03e16503113452df97922ecf2bb457aea7d2b1
parent  df084ac7be3205ed039f50dabbc598ed8160ffe4
0
python/tests/examples/word_count.py 
...
1
2
3
 
4
5
 
 
 
6
7
8
 
...
1
2
3
4
5
 
6
7
8
9
10
11
 
0
@@ -1,8 +1,11 @@
0
 #!/usr/bin/env python
0
 # encoding: utf-8
0
 
0
+# only necessary because we want to use the non-installed version of the lib
0
 import sys
0
-sys.path.append('src')
0
+sys.path.insert(0, 'src')
0
+
0
+
0
 from collections import defaultdict
0
 from hadoop import Job
0
 
0
python/tests/helpers.py 
...
1
2
 
3
4
5
 
...
1
 
2
3
4
5
 
0
@@ -1,5 +1,5 @@
0
 import sys, unittest
0
-sys.path.append('src')
0
+sys.path.insert(0, 'src')
0
 
0
 def fixedGetTestCaseNames(self, testCaseClass):
0
   """Return a sorted sequence of method names found within testCaseClass

Comments

    No one has commented yet.