Package org.moeaframework.analysis.store

Class TransactionalOutputStream

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

org.moeaframework.analysis.store.TransactionalOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public abstract class TransactionalOutputStream
extends FilterOutputStream

Output stream with a transaction mechanism requiring one to call commit() before the content is stored. The typical use is:

   try (TransactionalOutputStream out = blob.openOutputStream()) {
       out.write(...);
       out.commit();
   }
 

Field Summary

Fields inherited from class java.io.FilterOutputStream

out

Constructor Summary

Constructors

Constructor	Description
TransactionalOutputStream(OutputStream out)	Constructs a transactional output stream.

Method Summary

Modifier and Type	Method	Description
void	close()
void	commit()	Indicates the content was successfully written.
protected abstract void	doCommit()	Called during close() to commit or complete the transaction.
protected abstract void	doRollback()	Called during close() to rollback the transaction.

Methods inherited from class java.io.FilterOutputStream

flush, write, write, write

Methods inherited from class java.io.OutputStream

nullOutputStream

Methods inherited from class java.lang.Object

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

Constructor Details

TransactionalOutputStream

public TransactionalOutputStream(OutputStream out)

Constructs a transactional output stream.

Parameters:

out - the temporary output stream, where content is written before it is committed

Method Details

commit

public void commit()
            throws IOException

Indicates the content was successfully written. This method must be called before close() to take effect.

Throws:

IOException - if an I/O error occurred

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class FilterOutputStream

Throws:

IOException

doCommit

protected abstract void doCommit()
                          throws IOException

Called during close() to commit or complete the transaction.

Throws:

IOException - if an I/O error occurred

doRollback

protected abstract void doRollback()
                            throws IOException

Called during close() to rollback the transaction.

Throws:

IOException - if an I/O error occurred