Contents

require_relative 'all_jobs_shared'

class ParametersJob
  include AllJobsShared

  define_param :test_parameter, "my test parameter value"

  define_target :source_data, Remi::DataSource::DataFrame,
    fields: {
      :parameter_name => {}
    }
  define_target :target_data, Remi::DataTarget::DataFrame

  define_transform :main do
    Remi::SourceToTargetMap.apply(source_data.df, target_data.df) do
      map source(nil) .target(:myparam)
        .transform(Remi::Transform[:constant].(params[:myparam]))
      map source(:parameter_name) .target(:parameter_name)
        .transform(->(v) { params[v.to_sym] })
    end
  end

end

Version data entries

13 entries across 13 versions & 1 rubygems

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