public static interface FilterPlugin.Control
Modifier and Type | Method and Description |
---|---|
void |
run(org.embulk.config.TaskSource taskSource,
org.embulk.spi.Schema outputSchema)
Runs the following tasks of the Filter Plugin.
|
void run(org.embulk.config.TaskSource taskSource, org.embulk.spi.Schema outputSchema)
It would be executed at the end of
FilterPlugin.transaction(org.embulk.config.ConfigSource, org.embulk.spi.Schema, FilterPlugin.Control)
.
taskSource
- TaskSource
processed for tasks from ConfigSource
outputSchema
- Schema
of the output from the filter