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 processorCount,
            OutputPlugin.Control control);

    public ConfigDiff resume(TaskSource taskSource,
            Schema schema, int processorCount,
            OutputPlugin.Control control);

    public void cleanup(TaskSource taskSource,
            Schema schema, int processorCount,
            List<CommitReport> successCommitReports);

    public TransactionalPageOutput open(TaskSource taskSource, Schema schema, int processorIndex);
}

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
embulk-0.4.3	embulk-core/src/main/java/org/embulk/spi/OutputPlugin.java
embulk-0.4.2	embulk-core/src/main/java/org/embulk/spi/OutputPlugin.java
embulk-0.4.1	embulk-core/src/main/java/org/embulk/spi/OutputPlugin.java
embulk-0.4.0	embulk-core/src/main/java/org/embulk/spi/OutputPlugin.java