diff options
author | Patrick Simianer <simianer@cl.uni-heidelberg.de> | 2012-04-23 21:30:26 +0200 |
---|---|---|
committer | Patrick Simianer <simianer@cl.uni-heidelberg.de> | 2012-04-23 21:30:26 +0200 |
commit | 6d0d0eb6bbfaee6b6998659a55e2195977ccd217 (patch) | |
tree | 48230318fd25f94f020560c387d63054f6a7b98b /dtrain/hstreaming/lplp.rb | |
parent | 715245dc7042ac0dca4fea94031d7c6de8058033 (diff) |
NEXT
Diffstat (limited to 'dtrain/hstreaming/lplp.rb')
-rwxr-xr-x | dtrain/hstreaming/lplp.rb | 4 |
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 |