Class DataSinkStream

  • All Implemented Interfaces:
    DataSink

    public class DataSinkStream
    extends java.lang.Object
    implements DataSink
    Reference implementation of DataSink. It can be used with non-parallel transfers. It cannot be used with Extended Block Mode because it uses implicit assumption that data arrives in correct sequence. It is not thread safe.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected boolean autoFlush  
      protected boolean ignoreOffset  
      protected long offset  
      protected java.io.OutputStream out  
    • Constructor Summary

      Constructors 
      Constructor Description
      DataSinkStream​(java.io.OutputStream out)  
      DataSinkStream​(java.io.OutputStream out, boolean autoFlush, boolean ignoreOffset)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()
      Closes this data sink and releases any system resources associated with this sink.
      void write​(Buffer buffer)
      Writes the specified buffer to this data sink.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • out

        protected java.io.OutputStream out
      • autoFlush

        protected boolean autoFlush
      • ignoreOffset

        protected boolean ignoreOffset
      • offset

        protected long offset
    • Constructor Detail

      • DataSinkStream

        public DataSinkStream​(java.io.OutputStream out)
      • DataSinkStream

        public DataSinkStream​(java.io.OutputStream out,
                              boolean autoFlush,
                              boolean ignoreOffset)
    • Method Detail

      • write

        public void write​(Buffer buffer)
                   throws java.io.IOException
        Description copied from interface: DataSink
        Writes the specified buffer to this data sink.
        Note: buffer.getOffset() might return -1 if the transfer mode used does not support data offsets, for example stream transfer mode.
        Specified by:
        write in interface DataSink
        Parameters:
        buffer - the data buffer to write.
        Throws:
        java.io.IOException - if an I/O error occurs.
      • close

        public void close()
                   throws java.io.IOException
        Description copied from interface: DataSink
        Closes this data sink and releases any system resources associated with this sink.
        Specified by:
        close in interface DataSink
        Throws:
        java.io.IOException - if an I/O error occurs.