Contents

require_relative '../all_jobs_shared'

class NvlJob
  include AllJobsShared

  define_param :default, ''
  define_source :source_data, Remi::DataSource::DataFrame,
    fields: {
      :field1 => {},
      :field2 => {},
      :field3 => {}
    }
  define_target :target_data, Remi::DataTarget::DataFrame

  define_transform :main, sources: :source_data, targets: :target_data do
    Remi::SourceToTargetMap.apply(source_data.df, target_data.df) do
      map source(:field1, :field2, :field3) .target(:result_field)
        .transform(Remi::Transform[:nvl].(params[:default]))
    end
  end
end

Version data entries

15 entries across 15 versions & 1 rubygems

Version	Path
remi-0.2.27	jobs/transforms/nvl_job.rb
remi-0.2.26	jobs/transforms/nvl_job.rb
remi-0.2.25	jobs/transforms/nvl_job.rb
remi-0.2.24	jobs/transforms/nvl_job.rb
remi-0.2.23	jobs/transforms/nvl_job.rb
remi-0.2.22	jobs/transforms/nvl_job.rb
remi-0.2.21	jobs/transforms/nvl_job.rb
remi-0.2.20	jobs/transforms/nvl_job.rb
remi-0.2.19	jobs/transforms/nvl_job.rb
remi-0.2.18	jobs/transforms/nvl_job.rb
remi-0.2.17	jobs/transforms/nvl_job.rb
remi-0.2.16	jobs/transforms/nvl_job.rb
remi-0.2.15	jobs/transforms/nvl_job.rb
remi-0.2.14	jobs/transforms/nvl_job.rb
remi-0.2.13	jobs/transforms/nvl_job.rb