org.embulk.util.config

Class TaskMapper

java.lang.Object

org.embulk.util.config.TaskMapper

public final class TaskMapper
extends Object

Maps org.embulk.config.TaskSource into a task-defining interface that inherits Task.

It performs the same job with Embulk core's ConfigSource#loadTask on plugin's side.

 public class ExampleInputPlugin implements InputPlugin {
     public ExampleInputPlugin() {
         this.configMapperFactory = org.embulk.util.config.ConfigMapperFactory.withDefault();
     }

     public interface PluginTask extends org.embulk.util.config.Task {
         // ...
     }

     public ConfigDiff transaction(ConfigSource config, InputPlugin.Control control) {
         // ...
     }

     public TaskReport run(TaskSource taskSource, Schema schema, int taskIndex, PageOutput output) {
         final org.embulk.util.config.TaskMapper taskMapper = this.configMapperFactory.createTaskMapper();
         final PluginTask task = taskMapper.map(taskSource, PluginTask.class);
         // ...
     }

     // ...

     private org.embulk.util.config.ConfigMapperFactory configMapperFactory;
 }

Method Summary

Modifier and Type	Method and Description
<T extends Task> T	map(TaskSource task, Class<T> taskType) Maps org.embulk.config.TaskSource into a task-defining interface that inherits Task.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

map

public <T extends Task> T map(TaskSource task,
                              Class<T> taskType)

Maps org.embulk.config.TaskSource into a task-defining interface that inherits Task.

Type Parameters:

T - the task-defining interface

Parameters:

task - org.embulk.config.TaskSource to map from

taskType - Class of the task-defining interface

Returns:

a mapped task instance