org.embulk.spi

Interface FilterPlugin.Control

Enclosing interface:

FilterPlugin

public static interface FilterPlugin.Control

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

Method Summary

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.

Method Detail

run

void run(org.embulk.config.TaskSource taskSource,
         org.embulk.spi.Schema outputSchema)

Runs the following tasks of the Filter Plugin.

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

Parameters:

taskSource - TaskSource processed for tasks from ConfigSource

outputSchema - Schema of the output from the filter