Sha256: 542231a12aa1dcef2bb78d418519f73ee1ecd8dbe07f7775403ade9b8dd12875

Contents?: true

Size: 939 Bytes

Versions: 29

Compression:

Stored size: 939 Bytes

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

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

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

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

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

    public ConfigDiff guess(ConfigSource config);
}

Version data entries

29 entries across 29 versions & 1 rubygems

Version Path
embulk-0.6.22 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.21 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.20 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.19 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.18 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.17 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.16 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.15 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.14 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.13 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.12 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.11 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.10 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.9 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.8 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.7 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.6 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.5 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.4 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java
embulk-0.6.3 embulk-core/src/main/java/org/embulk/spi/InputPlugin.java