org.embulk.spi

Interface OutputPlugin

public interface OutputPlugin

The main class that an Output Plugin implements.

An Output Plugin writes a sequence of data records in Pages read from an Input Plugin, or a Filter Plugin, into the configured destination.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	OutputPlugin.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, org.embulk.spi.Schema schema, int taskCount, List<org.embulk.config.TaskReport> successTaskReports) Cleans up resources used in the transaction.
org.embulk.spi.TransactionalPageOutput	open(org.embulk.config.TaskSource taskSource, org.embulk.spi.Schema schema, int taskIndex) Opens a TransactionalPageOutput instance that receives Pages from an Input Plugin, or a Filter Plugin, and writes them into the configured destination.
org.embulk.config.ConfigDiff	resume(org.embulk.config.TaskSource taskSource, org.embulk.spi.Schema schema, int taskCount, OutputPlugin.Control control) Resumes an output transaction.
org.embulk.config.ConfigDiff	transaction(org.embulk.config.ConfigSource config, org.embulk.spi.Schema schema, int taskCount, OutputPlugin.Control control) Processes the entire output transaction.

Method Detail

transaction

org.embulk.config.ConfigDiff transaction(org.embulk.config.ConfigSource config,
                                         org.embulk.spi.Schema schema,
                                         int taskCount,
                                         OutputPlugin.Control control)

Processes the entire output transaction.

Parameters:

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

schema - Schema of the output

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,
                                    org.embulk.spi.Schema schema,
                                    int taskCount,
                                    OutputPlugin.Control control)

Resumes an output transaction.

Parameters:

taskSource - a configuration processed for the task from ConfigSource

schema - Schema of the output

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,
             org.embulk.spi.Schema schema,
             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

schema - Schema of the output

taskCount - the number of tasks

successTaskReports - reports of successful tasks

open

org.embulk.spi.TransactionalPageOutput open(org.embulk.config.TaskSource taskSource,
                                            org.embulk.spi.Schema schema,
                                            int taskIndex)

Opens a TransactionalPageOutput instance that receives Pages from an Input Plugin, or a Filter Plugin, and writes them into the configured destination.

It processes each output task.

Parameters:

taskSource - a configuration processed for the task from ConfigSource

schema - Schema of the output

taskIndex - the index number of the task

Returns:

an implementation of TransactionalPageOutput that receives Pages from an Input Plugin, or a Filter Plugin, and writes them into the configured destination