Sha256: 220d48a1f671b588d312cc344e6d4d81db4ef61bdfae380bb2586b3fef505d3f
Contents?: true
Size: 746 Bytes
Versions: 104
Compression:
Stored size: 746 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 FileOutputPlugin
{
interface Control
{
List<TaskReport> run(TaskSource taskSource);
}
ConfigDiff transaction(ConfigSource config, int taskCount,
FileOutputPlugin.Control control);
ConfigDiff resume(TaskSource taskSource,
int taskCount,
FileOutputPlugin.Control control);
void cleanup(TaskSource taskSource,
int taskCount,
List<TaskReport> successTaskReports);
TransactionalFileOutput open(TaskSource taskSource, int taskIndex);
}
Version data entries
104 entries across 104 versions & 1 rubygems