Contents

package org.embulk.standards;

import com.google.common.base.Preconditions;
import com.google.inject.Binder;
import com.google.inject.Module;
import org.embulk.spi.FilterPlugin;
import org.embulk.spi.FormatterPlugin;
import org.embulk.spi.InputPlugin;
import org.embulk.spi.OutputPlugin;
import org.embulk.spi.ParserPlugin;
import org.embulk.spi.DecoderPlugin;
import org.embulk.spi.EncoderPlugin;
import org.embulk.plugin.PluginType;
import static org.embulk.plugin.InjectedPluginSource.registerPluginTo;
import static org.embulk.exec.GuessExecutor.registerDefaultGuessPluginTo;

public class StandardPluginModule
        implements Module
{
    @Override
    public void configure(Binder binder)
    {
        Preconditions.checkNotNull(binder, "binder is null.");

        // input plugins
        registerPluginTo(binder, InputPlugin.class, "file", LocalFileInputPlugin.class);

        // parser plugins
        registerPluginTo(binder, ParserPlugin.class, "csv", CsvParserPlugin.class);

        // file decoder plugins
        registerPluginTo(binder, DecoderPlugin.class, "gzip", GzipFileDecoderPlugin.class);

        // output plugins
        registerPluginTo(binder, OutputPlugin.class, "file", LocalFileOutputPlugin.class);
        registerPluginTo(binder, OutputPlugin.class, "null", NullOutputPlugin.class);
        registerPluginTo(binder, OutputPlugin.class, "stdout", StdoutOutputPlugin.class);

        // formatter plugins
        registerPluginTo(binder, FormatterPlugin.class, "csv", CsvFormatterPlugin.class);

        // file encoder plugins
        registerPluginTo(binder, EncoderPlugin.class, "gzip", GzipFileEncoderPlugin.class);

        // filter plugins
        registerPluginTo(binder, FilterPlugin.class, "rename", RenameFilterPlugin.class);

        // default guess plugins
        registerDefaultGuessPluginTo(binder, new PluginType("gzip"));
        registerDefaultGuessPluginTo(binder, new PluginType("csv"));
        // charset and newline guess plugins are loaded and invoked by CsvGuessPlugin
    }
}

Version data entries

32 entries across 32 versions & 1 rubygems

Version	Path
embulk-0.8.3	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.8.3-java	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.11	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.11-java	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.8.2	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.8.2-java	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.8.1	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.8.1-java	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.8.0	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.8.0-java	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.10	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.10-java	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.9	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.9-java	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.8	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.8-java	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.7	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.7-java	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.6	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java
embulk-0.7.6-java	embulk-standards/src/main/java/org/embulk/standards/StandardPluginModule.java