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
All Methods Instance Methods Abstract Methods 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
-
-
-
-
Method Detail
-
cancel
public abstract void cancel() throws IOException
Cancel all of the writes associated with this stream and close it.- Throws:
IOException
-
-