water

Class H2O

java.lang.Object

water.H2O

public final class H2O
extends java.lang.Object

Start point for creating or joining an H2O Cloud.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	H2O.H2OCountedCompleter<T extends H2O.H2OCountedCompleter>
static class	H2O.OptArgs

Field Summary

Fields

Modifier and Type	Field and Description
H2ONode[]	_memary
static AbstractBuildVersion	ABV
static byte	ACK_ACK_PRIORITY
static byte	ACK_PRIORITY
static int	API_PORT
static H2O.OptArgs	ARGS
static byte	ATOMIC_PRIORITY
static H2O	CLOUD
static java.net.InetAddress	CLOUD_MULTICAST_GROUP
static java.net.NetworkInterface	CLOUD_MULTICAST_IF
static int	CLOUD_MULTICAST_PORT
static java.net.MulticastSocket	CLOUD_MULTICAST_SOCKET
static byte	DESERIAL_PRIORITY
static byte	FETCH_ACK_PRIORITY
static byte	GET_KEY_PRIORITY
static byte	GUI_PRIORITY
static int	H2O_PORT
static java.net.URI	ICE_ROOT
static byte	INVALIDATE_PRIORITY
static byte	MAX_PRIORITY
static byte	MIN_HI_PRIORITY
static byte	MIN_PRIORITY
static int	NUMCPUS
static long	PID
static byte	PUT_KEY_PRIORITY
static H2ONode	SELF
static java.net.InetAddress	SELF_ADDRESS
static java.util.concurrent.atomic.AtomicLong	START_TIME_MILLIS
static java.util.HashSet<H2ONode>	STATIC_H2OS

Method Summary

Methods

Modifier and Type	Method and Description
static boolean	containsKey(Key key)
static java.lang.String	DEFAULT_ICE_ROOT()
static void	die(java.lang.String s)
static void	exit(int status) Notify embedding software instance H2O wants to exit.
static java.lang.RuntimeException	fail()
static java.lang.RuntimeException	fail(java.lang.String msg)
static java.lang.Runnable	finalizeRequest() Start the web service; disallow future URL registration.
static Value	get(Key key)
static int	getCloudSize()
static void	joinOthers()
static java.util.Set<Key>	localKeySet()
static void	main(java.lang.String[] args)
H2ONode[]	members()
long	memsz()
static Value	putIfMatch(Key key, Value val, Value old)
static void	registerGET(java.lang.String url_pattern, java.lang.Class hclass, java.lang.String hmeth, java.lang.String base_url, java.lang.String label, java.lang.String menu)
static void	registerResourceRoot(java.io.File f)
int	size()
static int	store_size()
static java.lang.String	STOREtoString()
static H2O.H2OCountedCompleter	submitTask(H2O.H2OCountedCompleter task)
java.lang.String	toString()
static java.lang.RuntimeException	unimpl()
static java.lang.RuntimeException	unimpl(java.lang.String msg)
static void	waitForCloudSize(int x, long ms)

Methods inherited from class java.lang.Object

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

Field Detail

ABV

public static final AbstractBuildVersion ABV

START_TIME_MILLIS

public static final java.util.concurrent.atomic.AtomicLong START_TIME_MILLIS

NUMCPUS

public static final int NUMCPUS

PID

public static long PID

MAX_PRIORITY

public static final byte MAX_PRIORITY

See Also:

Constant Field Values

ACK_ACK_PRIORITY

public static final byte ACK_ACK_PRIORITY

See Also:

Constant Field Values

FETCH_ACK_PRIORITY

public static final byte FETCH_ACK_PRIORITY

See Also:

Constant Field Values

ACK_PRIORITY

public static final byte ACK_PRIORITY

See Also:

Constant Field Values

DESERIAL_PRIORITY

public static final byte DESERIAL_PRIORITY

See Also:

Constant Field Values

INVALIDATE_PRIORITY

public static final byte INVALIDATE_PRIORITY

See Also:

Constant Field Values

GET_KEY_PRIORITY

public static final byte GET_KEY_PRIORITY

See Also:

Constant Field Values

PUT_KEY_PRIORITY

public static final byte PUT_KEY_PRIORITY

See Also:

Constant Field Values

ATOMIC_PRIORITY

public static final byte ATOMIC_PRIORITY

See Also:

Constant Field Values

GUI_PRIORITY

public static final byte GUI_PRIORITY

See Also:

Constant Field Values

MIN_HI_PRIORITY

public static final byte MIN_HI_PRIORITY

See Also:

Constant Field Values

MIN_PRIORITY

public static final byte MIN_PRIORITY

See Also:

Constant Field Values

ARGS

public static final H2O.OptArgs ARGS

H2O_PORT

public static int H2O_PORT

API_PORT

public static int API_PORT

CLOUD_MULTICAST_SOCKET

public static java.net.MulticastSocket CLOUD_MULTICAST_SOCKET

CLOUD_MULTICAST_IF

public static java.net.NetworkInterface CLOUD_MULTICAST_IF

CLOUD_MULTICAST_GROUP

public static java.net.InetAddress CLOUD_MULTICAST_GROUP

CLOUD_MULTICAST_PORT

public static int CLOUD_MULTICAST_PORT

SELF

public static H2ONode SELF

SELF_ADDRESS

public static java.net.InetAddress SELF_ADDRESS

ICE_ROOT

public static java.net.URI ICE_ROOT

STATIC_H2OS

public static java.util.HashSet<H2ONode> STATIC_H2OS

CLOUD

public static volatile H2O CLOUD

_memary

public final H2ONode[] _memary

Method Detail

unimpl

public static java.lang.RuntimeException unimpl()

unimpl

public static java.lang.RuntimeException unimpl(java.lang.String msg)

fail

public static java.lang.RuntimeException fail()

fail

public static java.lang.RuntimeException fail(java.lang.String msg)

submitTask

public static H2O.H2OCountedCompleter submitTask(H2O.H2OCountedCompleter task)

DEFAULT_ICE_ROOT

public static java.lang.String DEFAULT_ICE_ROOT()

registerGET

public static void registerGET(java.lang.String url_pattern,
               java.lang.Class hclass,
               java.lang.String hmeth,
               java.lang.String base_url,
               java.lang.String label,
               java.lang.String menu)

registerResourceRoot

public static void registerResourceRoot(java.io.File f)

finalizeRequest

public static java.lang.Runnable finalizeRequest()

Start the web service; disallow future URL registration. Returns a Runnable that will be notified once the server is up.

size

public final int size()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

members

public H2ONode[] members()

memsz

public long memsz()

waitForCloudSize

public static void waitForCloudSize(int x,
                    long ms)

getCloudSize

public static int getCloudSize()

joinOthers

public static void joinOthers()

putIfMatch

public static Value putIfMatch(Key key,
               Value val,
               Value old)

get

public static Value get(Key key)

containsKey

public static boolean containsKey(Key key)

localKeySet

public static java.util.Set<Key> localKeySet()

store_size

public static int store_size()

STOREtoString

public static java.lang.String STOREtoString()

main

public static void main(java.lang.String[] args)

exit

public static void exit(int status)

Notify embedding software instance H2O wants to exit.

Parameters:

status - H2O's requested process exit value.

die

public static void die(java.lang.String s)