Sha256: c0fcd9eb85c6c9617b4c156885d0d129342f041a9c51e56e99969127a3f72508
Contents?: true
Size: 888 Bytes
Versions: 7
Compression:
Stored size: 888 Bytes
Contents
package org.embulk.spi;
import java.util.List;
import org.embulk.config.TaskSource;
import org.embulk.config.ConfigSource;
import org.embulk.config.ConfigDiff;
import org.embulk.config.CommitReport;
public interface InputPlugin
{
public interface Control
{
public List<CommitReport> run(TaskSource taskSource,
Schema schema, int taskCount);
}
public ConfigDiff transaction(ConfigSource config,
InputPlugin.Control control);
public ConfigDiff resume(TaskSource taskSource,
Schema schema, int taskCount,
InputPlugin.Control control);
public void cleanup(TaskSource taskSource,
Schema schema, int taskCount,
List<CommitReport> successCommitReports);
public CommitReport run(TaskSource taskSource,
Schema schema, int taskIndex,
PageOutput output);
}
Version data entries
7 entries across 7 versions & 1 rubygems