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 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