public static interface InputPlugin.Control
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.
|
List<org.embulk.config.TaskReport> run(org.embulk.config.TaskSource taskSource, org.embulk.spi.Schema schema, int taskCount)
It would be executed at the end of InputPlugin.transaction(org.embulk.config.ConfigSource, InputPlugin.Control)
.
taskSource
- TaskSource
processed for tasks from ConfigSource
schema
- Schema
of the inputtaskCount
- the number of tasks