Package nz.org.riskscape.engine.io

Class DiskStorageReader

java.lang.Object
nz.org.riskscape.engine.io.DiskStorageReader
All Implemented Interfaces:
Closeable, AutoCloseable, nz.org.riskscape.engine.io.TupleReader
public class DiskStorageReader extends Object implements nz.org.riskscape.engine.io.TupleReader

Wraps a DataInputStreamTupleReader to apply byte counting and buffering to a FileOutputStream.

  • Constructor Details

  • Method Details

    • read

      public nz.org.riskscape.engine.Tuple read(nz.org.riskscape.engine.types.Struct expected) throws IOException
      Specified by:
      read in interface nz.org.riskscape.engine.io.TupleReader
      Throws:
      IOException

    • getBytesRead

      public long getBytesRead()

    • close

      public void close() throws IOException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Throws:
      IOException

    • getFile

      public File getFile()