water.persist

Class Persist

java.lang.Object

water.persist.Persist

Direct Known Subclasses:

PersistHdfs, PersistNFS, PersistS3

public abstract class Persist
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Persist.Schemes

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()
abstract void	delete(Value v)
static Persist	get(byte p)
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	store(Value v)
static byte[]	toByteArray(java.io.InputStream is)

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

get

public static Persist get(byte p)

getPath

public abstract java.lang.String getPath()

clear

public abstract void clear()

load

public abstract byte[] load(Value v)
                     throws java.io.IOException

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

Throws:

java.io.IOException

store

public abstract void store(Value v)

delete

public abstract void delete(Value v)

getUsableSpace

public long getUsableSpace()

getTotalSpace

public long getTotalSpace()

toByteArray

public static byte[] toByteArray(java.io.InputStream is)
                          throws java.io.IOException

Throws:

java.io.IOException