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 InputPlugin
{
    interface Control
    {
        List<CommitReport> run(TaskSource taskSource,
                Schema schema, int taskCount);
    }

    ConfigDiff transaction(ConfigSource config,
            InputPlugin.Control control);

    ConfigDiff resume(TaskSource taskSource,
            Schema schema, int taskCount,
            InputPlugin.Control control);

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

    CommitReport run(TaskSource taskSource,
            Schema schema, int taskIndex,
            PageOutput output);

    ConfigDiff guess(ConfigSource config);
}

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
embulk-0.6.27	embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.26	embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.25	embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.24	embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.23	embulk-core/src/main/java/org/embulk/spi/InputPlugin.java