water.persist

Class Persist<T>

java.lang.Object

water.persist.Persist<T>

Direct Known Subclasses:

PersistFS, PersistHdfs, PersistNFS, PersistS3, PersistTachyon

public abstract class Persist<T>
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static Persist[]	I
static long	UNKNOWN

Constructor Summary

Constructors

Constructor and Description
Persist()

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	clear()
T	createClient() Create a client to communicate with default URI server
T	createClient(java.lang.String uri) Create a client for given URI.
abstract void	delete(Value v)
java.lang.String	getDefaultURI() Return default URI of server to fetch data
static Persist	getIce()
abstract java.lang.String	getPath()
long	getTotalSpace()
long	getUsableSpace()
static void	initialize()
abstract byte[]	load(Value v) Value should already be persisted to disk.
abstract void	loadExisting() Load all Key/Value pairs that can be found on the backend.
abstract void	store(Value v)

Methods inherited from class java.lang.Object

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

Field Detail

I

public static final Persist[] I

UNKNOWN

public static final long UNKNOWN

See Also:

Constant Field Values

Constructor Detail

Persist

public Persist()

Method Detail

initialize

public static void initialize()

getIce

public static Persist getIce()

getPath

public abstract java.lang.String getPath()

clear

public abstract void clear()

loadExisting

public abstract void loadExisting()

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

load

public abstract byte[] load(Value v)

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).

store

public abstract void store(Value v)

delete

public abstract void delete(Value v)

getUsableSpace

public long getUsableSpace()

getTotalSpace

public long getTotalSpace()

getDefaultURI

public java.lang.String getDefaultURI()

Return default URI of server to fetch data

createClient

public final T createClient()
                     throws java.io.IOException

Create a client to communicate with default URI server

Throws:

java.io.IOException

createClient

public T createClient(java.lang.String uri)
               throws java.io.IOException

Create a client for given URI.

Throws:

java.io.IOException