org.embulk.spi

Interface DecoderPlugin

public interface DecoderPlugin

The main class that a Decoder Plugin implements.

It converts a byte sequence FileInput to another byte sequence FileInput.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	DecoderPlugin.Control A controller of the following tasks provided from the Embulk core.

Method Summary

Modifier and Type	Method and Description
org.embulk.spi.FileInput	open(org.embulk.config.TaskSource taskSource, org.embulk.spi.FileInput fileInput) Processes each decoding task.
void	transaction(org.embulk.config.ConfigSource config, DecoderPlugin.Control control) Processes the entire decoding transaction.

Method Detail

transaction

void transaction(org.embulk.config.ConfigSource config,
                 DecoderPlugin.Control control)

Processes the entire decoding transaction.

Parameters:

config - a configuration for the decoder plugin given from a user

control - a controller of the following tasks provided from the Embulk core

open

org.embulk.spi.FileInput open(org.embulk.config.TaskSource taskSource,
                              org.embulk.spi.FileInput fileInput)

Processes each decoding task.

Parameters:

taskSource - a configuration processed for the task from ConfigSource

fileInput - an input from a File Input Plugin, or another Decoder Plugin

Returns:

an input for a Parser Plugin, or another Decoder Plugin