Package org.apache.storm.blobstore

Class AtomicOutputStream

java.lang.Object

java.io.OutputStream

org.apache.storm.blobstore.AtomicOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

Direct Known Subclasses:

BlobStore.BlobStoreFileOutputStream, NimbusBlobStore.NimbusUploadAtomicOutputStream

public abstract class AtomicOutputStream
extends OutputStream

An output stream where all of the data is committed on close, or can be canceled with cancel.

Constructor Summary

Constructors

Constructor	Description
AtomicOutputStream()

Method Summary

Modifier and Type	Method	Description
abstract void	cancel()	Cancel all of the writes associated with this stream and close it.

Methods inherited from class java.io.OutputStream

close, flush, nullOutputStream, write, write, write

Methods inherited from class java.lang.Object

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

Constructor Details

AtomicOutputStream

public AtomicOutputStream()

Method Details

cancel

public abstract void cancel()
                     throws IOException

Cancel all of the writes associated with this stream and close it.

Throws:

IOException