Sha256: 64d9d199a92b763a3d77f74ac20c4901838dcf305689e7b199d48a965ed8d00d
Contents?: true
Size: 484 Bytes
Versions: 23
Compression:
Stored size: 484 Bytes
Contents
package org.embulk.spi;
import org.embulk.config.ConfigSource;
public interface ExecutorPlugin
{
public interface Executor
{
public void execute(ProcessTask task, ProcessState state);
}
public interface Control
{
public void transaction(Schema executorSchema, int outputTaskCount, Executor executor);
}
public void transaction(ConfigSource config, Schema outputSchema, int inputTaskCount,
ExecutorPlugin.Control control);
}
Version data entries
23 entries across 23 versions & 1 rubygems