Sha256: 916b19cb02834bba4f301a0ec61a4071d7fd1b775ba70bfe098cf554f5ec378a

Contents?: true

Size: 651 Bytes

Versions: 4

Compression:

Stored size: 651 Bytes

Contents

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]
}

Version data entries

4 entries across 4 versions & 3 rubygems

Version Path
activewarehouse-etl-1.0.0 test/delimited_with_bulk_load.ctl
activewarehouse-etl-1.0.0.rc1 test/delimited_with_bulk_load.ctl
etl-0.9.5.rc1 spec/fixtures/delimited_with_bulk_load.ctl
activewarehouse-etl-sgonyea-0.9.6 test/delimited_with_bulk_load.ctl