Contents

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

require 'cascading'
require 'samples/cascading'

cascade 'copy' do
  flow 'copy' do
    source 'input', tap('http://www.census.gov/genealogy/names/dist.all.last')

    assembly 'input' do
      rename 'line' => 'value'
      # We override validate_with because we know line will never be null
      reject 'value:string.indexOf("R") == -1', :validate_with => { :value => 'nothinghere' }
    end

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

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
cascading.jruby-0.0.6	samples/copy.rb
cascading.jruby-0.0.5	samples/copy.rb