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

Version	Path
embulk-0.6.2	embulk-core/src/main/java/org/embulk/spi/ExecutorPlugin.java
embulk-0.6.1	embulk-core/src/main/java/org/embulk/spi/ExecutorPlugin.java
embulk-0.6.0	embulk-core/src/main/java/org/embulk/spi/ExecutorPlugin.java