Contents

#! /usr/bin/env jruby
$: << File.join(File.dirname(__FILE__), '..', 'lib')

require 'cascading'
require 'samples/cascading'

cascade 'scorenames' do
  flow 'scorenames' do
    # You don't have to curl and cache inputs: tap can fetch via HTTP
    source 'input', tap('http://www.census.gov/genealogy/names/dist.all.last')

    assembly 'input' do
      split 'line', ['name', 'val1', 'val2', 'id']
      insert 'val3' => expr('val2:double < 40.0 ? val1:double : val2:double')
      project 'name', 'val3', 'id'
    end

    sink 'input', tap('output/scorenames', :sink_mode => :replace)
  end
end.complete(sample_properties)

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
cascading.jruby-0.0.6	samples/scorenames.rb
cascading.jruby-0.0.5	samples/scorenames.rb
cascading.jruby-0.0.4	samples/scorenames.rb