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