public interface DecoderPlugin
A Decoder Plugin converts a set of byte buffers in FileInput
to another set of byte buffers of
FileInput
.
Modifier and Type | Interface and Description |
---|---|
static interface |
DecoderPlugin.Control
A controller of the following tasks provided from the Embulk core.
|
Modifier and Type | Method and Description |
---|---|
org.embulk.spi.FileInput |
open(org.embulk.config.TaskSource taskSource,
org.embulk.spi.FileInput fileInput)
Opens a
FileInput instance that receives Buffer s from a File Input Plugin,
or another Decoder Plugin, so that decoded input is read from a Parser Plugin, or another Decoder Plugin |
void |
transaction(org.embulk.config.ConfigSource config,
DecoderPlugin.Control control)
Processes the entire decoding transaction.
|
void transaction(org.embulk.config.ConfigSource config, DecoderPlugin.Control control)
config
- a configuration for the Decoder Plugin given from a usercontrol
- a controller of the following tasks provided from the Embulk coreorg.embulk.spi.FileInput open(org.embulk.config.TaskSource taskSource, org.embulk.spi.FileInput fileInput)
FileInput
instance that receives Buffer
s from a File Input Plugin,
or another Decoder Plugin, so that decoded input is read from a Parser Plugin, or another Decoder Plugin
It processes each decoding task.
taskSource
- a configuration processed for the task from ConfigSource
fileInput
- FileInput
to read byte buffers from a File Input Plugin, or another Decoder PluginFileInput
that receives Buffer
s from a File
Input Plugin, or another Decoder Plugin, so that decoded input is read from a Parser Plugin, or another Decoder Plugin