org.embulk.spi

Interface FileOutputPlugin

public interface FileOutputPlugin

The main class that a File Output Plugin implements.

It writes TransactionalFileOutput as a byte sequence in a transaction.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	FileOutputPlugin.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.TransactionalFileOutput	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, FileOutputPlugin.Control control) Resumes a file output transaction.
org.embulk.config.ConfigDiff	transaction(org.embulk.config.ConfigSource config, int taskCount, FileOutputPlugin.Control control) Processes the entire file output transaction.

Method Detail

transaction

org.embulk.config.ConfigDiff transaction(org.embulk.config.ConfigSource config,
                                         int taskCount,
                                         FileOutputPlugin.Control control)

Processes the entire file output transaction.

Parameters:

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

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

resume

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

Resumes a file output 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.TransactionalFileOutput 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 output for a Formatter Plugin, or another Encoder Plugin