summaryrefslogtreecommitdiff
path: root/dtrain/hstreaming/lplp.rb
diff options
context:
space:
mode:
authorPatrick Simianer <simianer@cl.uni-heidelberg.de>2012-04-23 21:30:26 +0200
committerPatrick Simianer <simianer@cl.uni-heidelberg.de>2012-04-23 21:30:26 +0200
commit6d0d0eb6bbfaee6b6998659a55e2195977ccd217 (patch)
tree48230318fd25f94f020560c387d63054f6a7b98b /dtrain/hstreaming/lplp.rb
parent715245dc7042ac0dca4fea94031d7c6de8058033 (diff)
NEXT
Diffstat (limited to 'dtrain/hstreaming/lplp.rb')
-rwxr-xr-xdtrain/hstreaming/lplp.rb4
1 files changed, 2 insertions, 2 deletions
diff --git a/dtrain/hstreaming/lplp.rb b/dtrain/hstreaming/lplp.rb
index 40409bbd..57353adb 100755
--- a/dtrain/hstreaming/lplp.rb
+++ b/dtrain/hstreaming/lplp.rb
@@ -82,7 +82,7 @@ def _test()
cut(w, method(:mean), 1, 2.05)
exit
end
-_test()
+#_test()
# actually do something
def usage()
@@ -107,7 +107,7 @@ STDOUT.set_encoding 'utf-8'
w = {}
shard_count = 0
while line = STDIN.gets
- key, val = line.split /\t/
+ key, val = line.split /\s+/
if key == shard_count_key
shard_count += 1
next