water.persist

Class PersistTachyon.H2OTachyonInputStream

java.lang.Object

java.io.InputStream

water.util.RIStream

water.persist.PersistTachyon.H2OTachyonInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

PersistTachyon

public static final class PersistTachyon.H2OTachyonInputStream
extends RIStream

Field Summary

Fields inherited from class water.util.RIStream

_retries

Constructor Summary

Constructors

Modifier	Constructor and Description
	PersistTachyon.H2OTachyonInputStream(Key k, Job.ProgressMonitor pmon)
protected	PersistTachyon.H2OTachyonInputStream(Key k, long from, Job.ProgressMonitor pmon)

Method Summary

Methods

Modifier and Type	Method and Description
protected java.io.InputStream	open(long offset)

Methods inherited from class water.util.RIStream

available, close, closeQuietly, expectedSz, mark, markSupported, off, open, read, read, read, reset, setExpectedSz, skip

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PersistTachyon.H2OTachyonInputStream

protected PersistTachyon.H2OTachyonInputStream(Key k,
                                    long from,
                                    Job.ProgressMonitor pmon)

PersistTachyon.H2OTachyonInputStream

public PersistTachyon.H2OTachyonInputStream(Key k,
                                    Job.ProgressMonitor pmon)

Method Detail

open

protected java.io.InputStream open(long offset)
                            throws java.io.IOException

Specified by:

open in class RIStream

Throws:

java.io.IOException