Contents

package org.embulk.spi;

import java.util.List;
import org.embulk.config.TaskSource;
import org.embulk.config.ConfigSource;
import org.embulk.config.NextConfig;
import org.embulk.config.CommitReport;

public interface FileOutputPlugin
{
    public interface Control
    {
        public List<CommitReport> run(TaskSource taskSource);
    }

    public NextConfig transaction(ConfigSource config, int processorCount,
            FileOutputPlugin.Control control);

    public TransactionalFileOutput open(TaskSource taskSource, int processorIndex);
}

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
embulk-0.2.1	embulk-core/src/main/java/org/embulk/spi/FileOutputPlugin.java
embulk-0.2.0	embulk-core/src/main/java/org/embulk/spi/FileOutputPlugin.java
embulk-0.1.0	embulk-core/src/main/java/org/embulk/spi/FileOutputPlugin.java