Sha256: 1817418653b08c37b48cf82c2ee51d0384d020ac596f9457ce30d62adbbe13fb
Contents?: true
Size: 880 Bytes
Versions: 104
Compression:
Stored size: 880 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.TaskReport;
public interface InputPlugin
{
interface Control
{
List<TaskReport> run(TaskSource taskSource,
Schema schema, int taskCount);
}
ConfigDiff transaction(ConfigSource config,
InputPlugin.Control control);
ConfigDiff resume(TaskSource taskSource,
Schema schema, int taskCount,
InputPlugin.Control control);
void cleanup(TaskSource taskSource,
Schema schema, int taskCount,
List<TaskReport> successTaskReports);
TaskReport run(TaskSource taskSource,
Schema schema, int taskIndex,
PageOutput output);
ConfigDiff guess(ConfigSource config);
}
Version data entries
104 entries across 104 versions & 1 rubygems