Skip to content
Browse files

making gem version

  • Loading branch information...
1 parent ca05136 commit b087c05fe262c21bcedadce4b97bc73af069377c Philip (flip) Kromer committed
Showing with 14 additions and 2 deletions.
  1. +12 −0 CHANGELOG.textile
  2. +1 −0 README.textile
  3. +1 −2 lib/wukong/streamer/base.rb
View
12 CHANGELOG.textile
@@ -1,3 +1,15 @@
+h2. Wukong v1.4.7 2010-03-05
+
+Lots more examples:
+* examples/stats/avg_value_frequency.rb does an Average Value Frequency histogram
+* examples/server_logs has a quite useful apache log file parser
+* Made the base streamer use each_record, opening the door for alternative record injection (eg Datamapper!)
+* wukong/streamer/counting_reducer.rb is an um reducer and it counts things.
+
+h2. Wukong v1.4.6 2010-01-26
+
+* A HELLA AWESOME working example from retail web analytics by @lenbust
+
h2. Wukong v1.4.5 2010-01-18
* In @--run=local@ mode, you can use '-' alone as a filename to indicate STDIN / STDOUT as input/output respectively.
View
1 README.textile
@@ -220,6 +220,7 @@ Patches submitted by:
* ruby interpreter path fix by "Yuichiro MASUI":http://github.com/masuidrive - masui at masuidrive.jp - http://blog.masuidrive.jp/
Thanks to:
+* "Fredrik Möllerstrand (@lenbust)":http://twitter.com/lenbust for the examples/contrib/jeans working example
* "Brad Heintz":http://www.bradheintz.com/no1thing/talks/ for his early feedback
* "Phil Ripperger":http://blog.pdatasolutions.com for his "wukong in the Amazon AWS cloud":http://blog.pdatasolutions.com/post/191978092/ruby-on-hadoop-quickstart tutorial.
View
3 lib/wukong/streamer/base.rb
@@ -20,8 +20,7 @@ def stream
Log.info("Streaming on:\t%s" % [Script.input_file]) unless Script.input_file.blank?
before_stream
each_record do |line|
- record = recordize(line.chomp)
- next unless record
+ record = recordize(line.chomp) or next
process(*record) do |output_record|
emit output_record
end

0 comments on commit b087c05

Please sign in to comment.
Something went wrong with that request. Please try again.