Contents

#!/usr/bin/env ruby
require_relative './common'

class HistogramsMapper < Wukong::Streamer::ModelStreamer
  self.model_klass = Logline
  def process visit
    yield [visit.path, visit.day_hr]
  end
end

# Wukong.run( HistogramsMapper )
Wukong.run( HistogramsMapper )

Version data entries

6 entries across 6 versions & 2 rubygems

Version	Path
ul-wukong-4.1.1	examples/serverlogs/visit_paths/serverlogs-02-histograms-mapper.rb
ul-wukong-4.1.0	examples/serverlogs/visit_paths/serverlogs-02-histograms-mapper.rb
wukong-4.0.0	examples/serverlogs/visit_paths/serverlogs-02-histograms-mapper.rb
wukong-3.0.1	examples/serverlogs/visit_paths/serverlogs-02-histograms-mapper.rb
wukong-3.0.0	examples/serverlogs/visit_paths/serverlogs-02-histograms-mapper.rb
wukong-3.0.0.pre3	examples/serverlogs/visit_paths/serverlogs-02-histograms-mapper.rb