water.persist
Class Persist

java.lang.Object
  water.persist.Persist

Direct Known Subclasses:

PersistFS, PersistHdfs, PersistNFS, PersistS3

public abstract class Persist
extends java.lang.Object

Field Summary

static Persist[]	I
static long	UNKNOWN

Constructor Summary

Persist()

Method Summary

abstract void	clear()
abstract void	delete(Value v)
static Persist	getIce()
abstract java.lang.String	getPath()
long	getTotalSpace()
long	getUsableSpace()
static void	initialize()
abstract Value	lazyArrayChunk(Key key) Lazily manifest data chunks on demand.
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&delete is a bug no matter what).

store

public abstract void store(Value v)

delete

public abstract void delete(Value v)

lazyArrayChunk

public abstract Value lazyArrayChunk(Key key)

Lazily manifest data chunks on demand.

getUsableSpace

public long getUsableSpace()

getTotalSpace

public long getTotalSpace()