Sha256: a6fddeec890ded20ffb8755da3b0d8a365a65ef8d37408d390f19e0d699440f0
Contents?: true
Size: 1.19 KB
Versions: 34
Compression:
Stored size: 1.19 KB
Contents
package org.embulk.<%= embulk_category %>;
import org.embulk.config.Config;
import org.embulk.config.ConfigDefault;
import org.embulk.config.ConfigDiff;
import org.embulk.config.ConfigSource;
import org.embulk.config.Task;
import org.embulk.config.TaskSource;
import org.embulk.spi.Column;
import org.embulk.spi.FilterPlugin;
import org.embulk.spi.PageOutput;
import org.embulk.spi.Schema;
public class <%= java_class_name %>
implements FilterPlugin
{
public interface PluginTask
extends Task
{
@Config("property1")
public String getProperty1();
@Config("property2")
@ConfigDefault("0")
public int getProperty2();
}
@Override
public void transaction(ConfigSource config, Schema inputSchema,
FilterPlugin.Control control)
{
PluginTask task = config.loadConfig(PluginTask.class);
Schema outputSchema = inputSchema;
control.run(task.dump(), outputSchema);
}
@Override
public PageOutput open(TaskSource taskSource, Schema inputSchema,
Schema outputSchema, PageOutput output)
{
PluginTask task = taskSource.loadTask(PluginTask.class);
// TODO
}
}
Version data entries
34 entries across 34 versions & 1 rubygems