summaryrefslogtreecommitdiff
path: root/hadoop/streaming/no_reducer.rb
diff options
context:
space:
mode:
Diffstat (limited to 'hadoop/streaming/no_reducer.rb')
-rwxr-xr-xhadoop/streaming/no_reducer.rb9
1 files changed, 9 insertions, 0 deletions
diff --git a/hadoop/streaming/no_reducer.rb b/hadoop/streaming/no_reducer.rb
new file mode 100755
index 0000000..4410b93
--- /dev/null
+++ b/hadoop/streaming/no_reducer.rb
@@ -0,0 +1,9 @@
+#!/usr/bin/env ruby
+
+
+i = 0
+while l = STDIN.gets
+ puts "line #{i} (#{l.strip})"
+ i+=1
+end
+