water

Class Value

java.lang.Object

water.Iced

water.Value

All Implemented Interfaces:

java.lang.Cloneable, ForkJoinPool.ManagedBlocker, Freezable

public final class Value
extends Iced
implements ForkJoinPool.ManagedBlocker

The core Value stored in the distributed K/V store. It contains an underlying byte[] which may be spilled to disk and freed by the MemoryManager.

Field Summary

Fields

Modifier and Type	Field and Description
Key	_key
int	_max
static byte	HDFS
static byte	ICE
static byte	NFS
static byte	S3
static byte	TCP

Constructor Summary

Constructors

Constructor and Description
Value(Key k, byte[] mem)
Value(Key k, Freezable pojo)
Value(Key k, Freezable pojo, byte be)
Value(Key k, int max, byte[] mem, short type, byte be)
Value(Key k, java.lang.String s)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	block() Possibly blocks the current thread.
java.lang.String	className()
void	freeMem()
void	freePOJO()
<T extends Iced> T	get()
<T extends Freezable> T	get(java.lang.Class<T> fc)
<T extends Freezable> T	getFreezable()
boolean	isFrame()
boolean	isKey()
boolean	isLockable()
boolean	isModel()
boolean	isPersisted()
boolean	isReleasable() Return true if blocking is unnecessary.
boolean	isSubclassOf(java.lang.Class clz)
static boolean	isSubclassOf(int type, java.lang.Class clz)
boolean	isVec()
boolean	isVecGroup()
byte[]	memOrLoad()
static java.lang.String	nameOfPersist(int x)
Freezable	rawPOJO()
Value	read_impl(AutoBuffer bb)
void	setdsk()
AutoBuffer	write_impl(AutoBuffer ab)

Methods inherited from class water.Iced

clone, frozenType, read, readJSON_impl, readJSON, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON

Methods inherited from class java.lang.Object

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

Field Detail

_key

public transient Key _key

_max

public int _max

ICE

public static final byte ICE

See Also:

Constant Field Values

HDFS

public static final byte HDFS

See Also:

Constant Field Values

S3

public static final byte S3

See Also:

Constant Field Values

NFS

public static final byte NFS

See Also:

Constant Field Values

TCP

public static final byte TCP

See Also:

Constant Field Values

Constructor Detail

Value

public Value(Key k,
     int max,
     byte[] mem,
     short type,
     byte be)

Value

public Value(Key k,
     byte[] mem)

Value

public Value(Key k,
     java.lang.String s)

Value

public Value(Key k,
     Freezable pojo)

Value

public Value(Key k,
     Freezable pojo,
     byte be)

Method Detail

className

public java.lang.String className()

rawPOJO

public Freezable rawPOJO()

freeMem

public final void freeMem()

freePOJO

public final void freePOJO()

memOrLoad

public final byte[] memOrLoad()

get

public <T extends Iced> T get()

get

public <T extends Freezable> T get(java.lang.Class<T> fc)

getFreezable

public <T extends Freezable> T getFreezable()

setdsk

public final void setdsk()

isPersisted

public final boolean isPersisted()

nameOfPersist

public static java.lang.String nameOfPersist(int x)

isSubclassOf

public boolean isSubclassOf(java.lang.Class clz)

isSubclassOf

public static boolean isSubclassOf(int type,
                   java.lang.Class clz)

isKey

public boolean isKey()

isFrame

public boolean isFrame()

isVecGroup

public boolean isVecGroup()

isLockable

public boolean isLockable()

isVec

public boolean isVec()

isModel

public boolean isModel()

write_impl

public AutoBuffer write_impl(AutoBuffer ab)

Specified by:

write_impl in interface Freezable

Overrides:

write_impl in class Iced

read_impl

public Value read_impl(AutoBuffer bb)

Specified by:

read_impl in interface Freezable

Overrides:

read_impl in class Iced

isReleasable

public boolean isReleasable()

Return true if blocking is unnecessary. Alas, used in TWO places and the blocking API forces them to share here.

Specified by:

isReleasable in interface ForkJoinPool.ManagedBlocker

block

public boolean block()

Possibly blocks the current thread. Returns true if isReleasable would return true. Used by the FJ Pool management to spawn threads to prevent deadlock is otherwise all threads would block on waits.

Specified by:

block in interface ForkJoinPool.ManagedBlocker

Returns:

true if no additional blocking is necessary (i.e., if isReleasable would return true)