org.embulk.util.config

Interface Task

public interface Task

A task-defining interface that is mapped from org.embulk.config.ConfigSource and org.embulk.config.TaskSource.

Embulk plugins usually need to define their own interface extending this Task. Then, org.embulk.config.ConfigSource and org.embulk.config.TaskSource are mapped into the extended interface with ConfigMapper and TaskMapper, respectively. See the example below.

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

     public interface PluginTask extends org.embulk.util.config.Task {
         @Config("config")
         String getConfigAsString();

         @Config("config")
         int getConfigAsInteger();

         @Config("someone")
         @ConfigDefault("any")
         String getSomeone();
     }

     public ConfigDiff transaction(final ConfigSource config, final InputPlugin.Control control) {
         final org.embulk.util.config.ConfigMapper configMapper = this.configMapperFactory.createConfigMapper();
         final PluginTask task = configMapper.map(config, PluginTask.class);
         // ...
     }

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

For core developers

The Task object generated by ConfigMapper and TaskMapper is implemented with Proxy, the dynamic proxy mechanism with reflection.

Method Summary

Modifier and Type	Method and Description
TaskSource	dump() Deprecated. Replaced with toTaskSource().
ObjectNode	toObjectNode() Dumps this Task as a ObjectNode.
TaskSource	toTaskSource() Dumps this Task as a org.embulk.config.TaskSource.
void	validate() Validates this Task with a Validator registered from ConfigMapperFactory.

Method Detail

validate

void validate()

Validates this Task with a Validator registered from ConfigMapperFactory.

Throws:

TaskValidationException - if this Task is invalid

dump

@Deprecated
TaskSource dump()

Deprecated. Replaced with toTaskSource().

Dumps this Task as a org.embulk.config.TaskSource.

Returns:

org.embulk.config.TaskSource dumped

toTaskSource

TaskSource toTaskSource()

Dumps this Task as a org.embulk.config.TaskSource.

Returns:

org.embulk.config.TaskSource dumped

toObjectNode

ObjectNode toObjectNode()

Dumps this Task as a ObjectNode.

Returns:

ObjectNode dumped