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
An output stream where all of the data is committed on close, or can be canceled with cancel.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionabstract 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
-
Constructor Details
-
AtomicOutputStream
public AtomicOutputStream()
-
-
Method Details
-
cancel
Cancel all of the writes associated with this stream and close it.- Throws:
IOException
-