Contents

package org.embulk.spi;

public interface ProcessState
{
    public void initialize(int inputTaskCount, int outputTaskCount);

    public TaskState getInputTaskState(int inputTaskIndex);

    public TaskState getOutputTaskState(int outputTaskIndex);
}

Version data entries

23 entries across 23 versions & 1 rubygems

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