org.embulk.util.file

Class InputStreamTransactionalFileInput

java.lang.Object

org.embulk.util.file.InputStreamFileInput

org.embulk.util.file.InputStreamTransactionalFileInput

All Implemented Interfaces:

AutoCloseable, FileInput, Transactional, TransactionalFileInput

public abstract class InputStreamTransactionalFileInput
extends InputStreamFileInput
implements TransactionalFileInput

Nested Class Summary

Nested classes/interfaces inherited from class org.embulk.util.file.InputStreamFileInput

InputStreamFileInput.InputStreamWithHints, InputStreamFileInput.IteratorProvider, InputStreamFileInput.Opener, InputStreamFileInput.Provider

Constructor Summary

Constructors

Constructor and Description
InputStreamTransactionalFileInput(BufferAllocator allocator, InputStream openedStream)
InputStreamTransactionalFileInput(BufferAllocator allocator, InputStreamFileInput.Opener opener)
InputStreamTransactionalFileInput(BufferAllocator allocator, InputStreamFileInput.Provider provider)

Method Summary

Methods inherited from class org.embulk.util.file.InputStreamFileInput

close, getHintOfCurrentInputFileNameForLogging, hintOfCurrentInputFileNameForLogging, nextFile, poll

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.embulk.spi.TransactionalFileInput

abort, close, commit, nextFile, poll

Methods inherited from interface org.embulk.spi.FileInput

hintOfCurrentInputFileNameForLogging

Constructor Detail

InputStreamTransactionalFileInput

public InputStreamTransactionalFileInput(BufferAllocator allocator,
                                         InputStreamFileInput.Provider provider)

InputStreamTransactionalFileInput

public InputStreamTransactionalFileInput(BufferAllocator allocator,
                                         InputStreamFileInput.Opener opener)

InputStreamTransactionalFileInput

public InputStreamTransactionalFileInput(BufferAllocator allocator,
                                         InputStream openedStream)