Sha256: a731458e93a4ea204a1547899cd372571f599533dad72151548b80b43ed654e1
Contents?: true
Size: 1.95 KB
Versions: 23
Compression:
Stored size: 1.95 KB
Contents
package org.embulk.<%= embulk_category %>;
import java.util.List;
import org.embulk.config.CommitReport;
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.Exec;
import org.embulk.spi.OutputPlugin;
import org.embulk.spi.PageOutput;
import org.embulk.spi.Schema;
import org.embulk.spi.TransactionalPageOutput;
public class <%= java_class_name %>
implements OutputPlugin
{
public interface PluginTask
extends Task
{
@Config("property1")
public String getProperty1();
@Config("property2")
@ConfigDefault("0")
public int getProperty2();
}
@Override
public ConfigDiff transaction(ConfigSource config,
Schema schema, int taskCount,
OutputPlugin.Control control)
{
PluginTask task = config.loadConfig(PluginTask.class);
// retryable (idempotent) output:
// return resume(task.dump(), schema, taskCount, control);
// non-retryable (non-idempotent) output:
control.run(task.dump());
return Exec.newConfigDiff();
}
@Override
public ConfigDiff resume(TaskSource taskSource,
Schema schema, int taskCount,
OutputPlugin.Control control)
{
throw new UnsupportedOperationException("<%= name %> output plugin does not support resuming");
}
@Override
public void cleanup(TaskSource taskSource,
Schema schema, int taskCount,
List<CommitReport> successCommitReports)
{
}
@Override
public TransactionalPageOutput open(TaskSource taskSource, Schema schema, int taskIndex)
{
PluginTask task = taskSource.loadTask(PluginTask.class);
// TODO
throw new UnsupportedOperationException("The 'open' method needs to be implemented");
}
}
Version data entries
23 entries across 23 versions & 1 rubygems