sam.io
Class ParallelIO.GatherOutputStream

java.lang.Object
  |
  +--java.io.OutputStream
        |
        +--sam.io.ParallelIO.GatherOutputStream
Enclosing class:
ParallelIO

public class ParallelIO.GatherOutputStream
extends java.io.OutputStream

Class for gathring buffered writes from multiple threads.

See Also:
ParallelIO.ScatterOutputStream

Constructor Summary
ParallelIO.GatherOutputStream(java.io.OutputStream delegee)
           
 
Method Summary
 void close()
          Simply forwards the closing call to the underlying stream
 void flush()
          Simply forwards the flushing call to the underlying stream
 void write(byte[] data, int begin, int length)
          Gathers data written by possibly multiple threads (and thus out-of-order) to the underlying stream
 void write(int b)
          Simply writes the single byte on the underlying stream
 
Methods inherited from class java.io.OutputStream
write
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ParallelIO.GatherOutputStream

public ParallelIO.GatherOutputStream(java.io.OutputStream delegee)
Method Detail

flush

public void flush()
           throws java.io.IOException
Simply forwards the flushing call to the underlying stream

Overrides:
flush in class java.io.OutputStream
java.io.IOException

close

public void close()
           throws java.io.IOException
Simply forwards the closing call to the underlying stream

Overrides:
close in class java.io.OutputStream
java.io.IOException

write

public void write(int b)
           throws java.io.IOException
Simply writes the single byte on the underlying stream

Specified by:
write in class java.io.OutputStream
java.io.IOException

write

public void write(byte[] data,
                  int begin,
                  int length)
           throws java.io.IOException
Gathers data written by possibly multiple threads (and thus out-of-order) to the underlying stream

Overrides:
write in class java.io.OutputStream
java.io.IOException