Contents

require_relative 'all_jobs_shared'

class CopySourceJob
  include AllJobsShared

  define_source :source_data, Remi::DataSource::DataFrame,
    fields: {
      :some_field => {},
      :some_date => { type: :date, format: '%Y-%m-%d' }
    }
  define_source :target_data, Remi::DataSource::DataFrame

  define_transform :main, sources: :source_data, targets: :target_data do
    target_data.df = source_data.df.dup
  end
end

Version data entries

15 entries across 15 versions & 1 rubygems

Version	Path
remi-0.2.42	jobs/copy_source_job.rb
remi-0.2.41	jobs/copy_source_job.rb
remi-0.2.40	jobs/copy_source_job.rb
remi-0.2.39	jobs/copy_source_job.rb
remi-0.2.38	jobs/copy_source_job.rb
remi-0.2.37	jobs/copy_source_job.rb
remi-0.2.36	jobs/copy_source_job.rb
remi-0.2.35	jobs/copy_source_job.rb
remi-0.2.34	jobs/copy_source_job.rb
remi-0.2.33	jobs/copy_source_job.rb
remi-0.2.32	jobs/copy_source_job.rb
remi-0.2.31	jobs/copy_source_job.rb
remi-0.2.30	jobs/copy_source_job.rb
remi-0.2.29	jobs/copy_source_job.rb
remi-0.2.28	jobs/copy_source_job.rb