Sha256: c55d1d17f91e798e34cbaf67c3857be544fdb0ee3507e76bc72db14a2413064c
Contents?: true
Size: 856 Bytes
Versions: 36
Compression:
Stored size: 856 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 OutputPlugin
{
public interface Control
{
public List<CommitReport> run(TaskSource taskSource);
}
public ConfigDiff transaction(ConfigSource config,
Schema schema, int taskCount,
OutputPlugin.Control control);
public ConfigDiff resume(TaskSource taskSource,
Schema schema, int taskCount,
OutputPlugin.Control control);
public void cleanup(TaskSource taskSource,
Schema schema, int taskCount,
List<CommitReport> successCommitReports);
public TransactionalPageOutput open(TaskSource taskSource, Schema schema, int taskIndex);
}
Version data entries
36 entries across 36 versions & 1 rubygems