org.embulk.spi

Interface FileInputPlugin

public interface FileInputPlugin

The main class that a File Input Plugin implements.

It reads a byte sequence into TransactionalFileInput in a transaction.

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method and Description
void	cleanup(org.embulk.config.TaskSource taskSource, int taskCount, List<org.embulk.config.TaskReport> successTaskReports) Cleans up resources used in the transaction.
org.embulk.spi.TransactionalFileInput	open(org.embulk.config.TaskSource taskSource, int taskIndex) Processes each file input task.
org.embulk.config.ConfigDiff	resume(org.embulk.config.TaskSource taskSource, int taskCount, FileInputPlugin.Control control) Resumes a file input transaction.
org.embulk.config.ConfigDiff	transaction(org.embulk.config.ConfigSource config, FileInputPlugin.Control control) Processes the entire file input transaction.

Method Detail

transaction

org.embulk.config.ConfigDiff transaction(org.embulk.config.ConfigSource config,
                                         FileInputPlugin.Control control)

Processes the entire file input transaction.

Parameters:

config - a configuration for the File Input Plugin given from a user

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

Returns:

ConfigDiff to represent the difference the next incremental run

resume

org.embulk.config.ConfigDiff resume(org.embulk.config.TaskSource taskSource,
                                    int taskCount,
                                    FileInputPlugin.Control control)

Resumes a file input transaction.

Parameters:

taskSource - a configuration processed for the task from ConfigSource

taskCount - the number of tasks

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

Returns:

ConfigDiff to represent the difference the next incremental run

cleanup

void cleanup(org.embulk.config.TaskSource taskSource,
             int taskCount,
             List<org.embulk.config.TaskReport> successTaskReports)

Cleans up resources used in the transaction.

Parameters:

taskSource - a configuration processed for the task from ConfigSource

taskCount - the number of tasks

successTaskReports - TaskReports of successful tasks

open

org.embulk.spi.TransactionalFileInput open(org.embulk.config.TaskSource taskSource,
                                           int taskIndex)

Processes each file input task.

Parameters:

taskSource - a configuration processed for the task from ConfigSource

taskIndex - the index number of the task

Returns:

an input for a Parser Plugin, or a Decoder Plugin