From 6d0d0eb6bbfaee6b6998659a55e2195977ccd217 Mon Sep 17 00:00:00 2001 From: Patrick Simianer Date: Mon, 23 Apr 2012 21:30:26 +0200 Subject: NEXT --- dtrain/hstreaming/lplp.rb | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'dtrain/hstreaming/lplp.rb') 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 -- cgit v1.2.3