Contents

#!/usr/bin/env ruby
require 'rubygems' unless defined?(Gem)
$LOAD_PATH.unshift(File.expand_path("../lib", File.dirname(__FILE__)))
require 'wukong'

load ARGV[0]

case File.basename($0)
when 'wu-map' then run_mode = :mapper
when 'wu-red' then run_mode = :reducer
end

Wukong::LocalRunner.new do
  source :stdin,  Wukong::Source::Stdin.new
  sink   :stdout, Wukong::Sink::Stdout.new
  flow   Wukong.dataflow(run_mode)
end.run

Version data entries

3 entries across 1 versions & 1 rubygems

Version	Path
wukong-3.0.0.pre	bin/wu-map
wukong-3.0.0.pre	bin/wu-red
wukong-3.0.0.pre	bin/wukong