water.persist

Class PersistTachyon

java.lang.Object

water.persist.Persist<tachyon.client.TachyonFS>

water.persist.PersistTachyon

public class PersistTachyon
extends Persist<tachyon.client.TachyonFS>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PersistTachyon.H2OTachyonInputStream

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_CLIENT_URI
static java.lang.String	PREFIX

Fields inherited from class water.persist.Persist

I, UNKNOWN

Method Summary

Methods

Modifier and Type	Method and Description
void	clear()
tachyon.client.TachyonFS	createClient(java.lang.String uri) Create a client for given URI.
static java.lang.String[]	decode(java.lang.String s)
void	delete(Value v)
java.lang.String	getDefaultURI() Return default URI of server to fetch data
java.lang.String	getPath()
byte[]	load(Value v) Value should already be persisted to disk.
void	loadExisting() Load all Key/Value pairs that can be found on the backend.
static java.io.InputStream	openStream(Key k, Job.ProgressMonitor pmon)
void	store(Value v)

Methods inherited from class water.persist.Persist

createClient, getIce, getTotalSpace, getUsableSpace, initialize

Methods inherited from class java.lang.Object

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

Field Detail

PREFIX

public static final java.lang.String PREFIX

See Also:

Constant Field Values

DEFAULT_CLIENT_URI

public static final java.lang.String DEFAULT_CLIENT_URI

See Also:

Constant Field Values

Method Detail

openStream

public static java.io.InputStream openStream(Key k,
                             Job.ProgressMonitor pmon)

load

public byte[] load(Value v)

Description copied from class: Persist

Value should already be persisted to disk. A racing delete can trigger a failure where we get a null return, but no crash (although one could argue that a racing load and delete is a bug no matter what).

Specified by:

load in class Persist<tachyon.client.TachyonFS>

decode

public static java.lang.String[] decode(java.lang.String s)

getPath

public java.lang.String getPath()

Specified by:

getPath in class Persist<tachyon.client.TachyonFS>

clear

public void clear()

Specified by:

clear in class Persist<tachyon.client.TachyonFS>

loadExisting

public void loadExisting()

Description copied from class: Persist

Load all Key/Value pairs that can be found on the backend.

Specified by:

loadExisting in class Persist<tachyon.client.TachyonFS>

store

public void store(Value v)

Specified by:

store in class Persist<tachyon.client.TachyonFS>

delete

public void delete(Value v)

Specified by:

delete in class Persist<tachyon.client.TachyonFS>

getDefaultURI

public java.lang.String getDefaultURI()

Description copied from class: Persist

Return default URI of server to fetch data

Overrides:

getDefaultURI in class Persist<tachyon.client.TachyonFS>

createClient

public tachyon.client.TachyonFS createClient(java.lang.String uri)
                                      throws java.io.IOException

Description copied from class: Persist

Create a client for given URI.

Overrides:

createClient in class Persist<tachyon.client.TachyonFS>

Throws:

java.io.IOException