org.embulk.spi

Interface InputPlugin.Control

Enclosing interface:

InputPlugin

public static interface InputPlugin.Control

A controller of the following tasks provided from the Embulk core.

Method Summary

Modifier and Type	Method and Description
List<org.embulk.config.TaskReport>	run(org.embulk.config.TaskSource taskSource, org.embulk.spi.Schema schema, int taskCount) Runs the following tasks of the Input Plugin.

Method Detail

run

List<org.embulk.config.TaskReport> run(org.embulk.config.TaskSource taskSource,
                                       org.embulk.spi.Schema schema,
                                       int taskCount)

Runs the following tasks of the Input Plugin.

It would be executed at the end of InputPlugin.transaction(org.embulk.config.ConfigSource, InputPlugin.Control).

Parameters:

taskSource - TaskSource processed for tasks from ConfigSource

schema - Schema of the input

taskCount - the number of tasks

Returns:

reports of tasks