org.embulk.spi

Interface TransactionalFileInput

All Superinterfaces:

AutoCloseable, FileInput, Transactional

public interface TransactionalFileInput
extends Transactional, FileInput

Represents a series of file-like byte sequence inputs in a transaction from a File Input Plugin.

Method Summary

Modifier and Type	Method and Description
void	abort() Aborts the transaction of TransactionalFileInput.
void	close() Closes this TransactionalFileInput.
TaskReport	commit() Commits the transaction of TransactionalFileInput.
boolean	nextFile() Switches the TransactionalFileInput to process the next file.
Buffer	poll() Reads a byte sequence from this TransactionalFileInput into Buffer.

Methods inherited from interface org.embulk.spi.FileInput

hintOfCurrentInputFileNameForLogging

Method Detail

nextFile

boolean nextFile()

Switches the TransactionalFileInput to process the next file.

Specified by:

nextFile in interface FileInput

Returns:

true if this TransactionalFileInput has switched to the next file. false if no more files.

poll

Buffer poll()

Reads a byte sequence from this TransactionalFileInput into Buffer.

Specified by:

poll in interface FileInput

Returns:

the Buffer read

close

void close()

Closes this TransactionalFileInput.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface FileInput

abort

void abort()

Aborts the transaction of TransactionalFileInput.

Specified by:

abort in interface Transactional

commit

TaskReport commit()

Commits the transaction of TransactionalFileInput.

Specified by:

commit in interface Transactional

Returns:

report