Sha256: 542231a12aa1dcef2bb78d418519f73ee1ecd8dbe07f7775403ade9b8dd12875
Contents?: true
Size: 939 Bytes
Versions: 29
Compression:
Stored size: 939 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); public ConfigDiff guess(ConfigSource config); }
Version data entries
29 entries across 29 versions & 1 rubygems