infile = 'data/people.txt'
outfile = 'output/people.txt'

source :in, {
  :file => infile,
  :parser => {
    :name => :csv
  }
}, 
[ 
  :first_name,
  :last_name,
]

before_write :surrogate_key, :target => :data_warehouse, :table => 'person_dimension', :column => 'id'
before_write :check_exist, {
  :target => :data_warehouse, 
  :table => 'person_dimension', 
  :columns => [:first_name, :last_name]
}

destination :out, {
  :file => outfile
},
{
  :order => [:id, :first_name, :last_name]
}

post_process :bulk_import, {
  :file => outfile,
  :target => :data_warehouse,
  :table => 'person_dimension',
  :order => [:id, :first_name, :last_name]
}