sam.io
Class ParallelIO.ScatterOutputStream

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

public class ParallelIO.ScatterOutputStream
extends java.io.OutputStream

Class for scattering buffered writes accross multiple threads.

See Also:
ParallelIO.GatherOutputStream

Constructor Summary
ParallelIO.ScatterOutputStream(java.io.OutputStream delegee, sam.toolkit.Workshop workshop)
           
 
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)
          Writes data using multiple threads 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.ScatterOutputStream

public ParallelIO.ScatterOutputStream(java.io.OutputStream delegee,
                                      sam.toolkit.Workshop workshop)
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
Writes data using multiple threads to the underlying stream

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