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.ApiIpPortWatchdogThread
static class	H2O.Cleaner
static class	H2O.FJWThr
static class	H2O.FlatFileEntry
static class	H2O.H2OCallback<T extends H2O.H2OCountedCompleter>
static class	H2O.H2OCountedCompleter
static class	H2O.H2OEmptyCompleter
static class	H2O.KeyInfo
static class	H2O.KVFilter
static class	H2O.OptArgs

Field Summary

Fields

Modifier and Type	Field and Description
static java.net.ServerSocket	_apiSocket
int	_hash
char	_idx
H2ONode[]	_memary
static java.nio.channels.DatagramChannel	_udpSocket
static byte	ACK_ACK_PRIORITY
static byte	ACK_PRIORITY
static int	API_PORT
static H2O.ApiIpPortWatchdogThread	apiIpPortWatchdog
static java.lang.String[]	ARGS
static byte	ARY_KEY_PRIORITY
static byte	ATOMIC_PRIORITY
static H2O	CLOUD
static boolean	DEBUG
static java.lang.String	DEBUG_ARG
static java.lang.String	DEFAULT_CREDENTIALS_LOCATION
static int	DEFAULT_PORT
static byte	DESERIAL_PRIORITY
static AbstractEmbeddedH2OConfig	embeddedH2OConfig
static java.io.PrintStream	ERR
static byte	GET_KEY_PRIORITY
static byte	GUI_PRIORITY
static java.net.URI	ICE_ROOT
static byte	INVALIDATE_PRIORITY
static boolean	IS_SYSTEM_RUNNING
static LicenseManager	licenseManager
static byte	MAX_PRIORITY
static byte	MIN_HI_PRIORITY
static byte	MIN_PRIORITY
static java.lang.String	NAME
static int	NUMCPUS
static H2O.OptArgs	OPT_ARGS
static java.io.PrintStream	OUT
static byte	PUT_KEY_PRIORITY
static H2ONode	SELF
static java.net.InetAddress	SELF_ADDRESS
static long	START_TIME_MILLIS
static java.util.HashSet<H2ONode>	STATIC_H2OS
static int	UDP_PORT
static java.lang.String	VERSION
static int	VOLATILE

Constructor Summary

Constructors

Constructor and Description
H2O(H2ONode[] h2os, int hash, int idx)

Method Summary

Methods

Modifier and Type	Method and Description
static java.util.ArrayList<java.net.InetAddress>	calcPrioritizedInetAddressList() Return a list of internet addresses sorted by importance (most important first).
boolean	contains(H2ONode h2o)
int	D(Key key, int repl)
static java.lang.String	DEFAULT_ICE_ROOT()
static void	exit(int status) Notify embedding software instance H2O wants to exit.
static java.lang.RuntimeException	fail()
static java.net.InetAddress	findInetAddressForSelf()
static Value	get(Key key)
static com.amazonaws.auth.PropertiesCredentials	getAWSCredentials()
static AbstractBuildVersion	getBuildVersion() Load a h2o build version or return default unknown version
static AbstractEmbeddedH2OConfig	getEmbeddedH2OConfig()
static Key	getk(Key key)
static java.lang.String	getVersion()
static H2O.KeyInfo[]	globalKeySet(H2O.KVFilter f, long timeTolerance)
static java.util.Set<Key>	globalKeySet(java.lang.String clzname)
static void	ignore(java.lang.Throwable e)
static void	ignore(java.lang.Throwable e, java.lang.String msg)
static void	ignore(java.lang.Throwable e, java.lang.String msg, boolean printException)
static boolean	isHealthy()
static boolean	larger(int nnn, int old)
H2ONode	leader()
static H2O.KeyInfo[]	localEntrySet(H2O.KVFilter f, boolean homeOnly, boolean userOnly)
static java.util.Set<Key>	localKeySet()
static void	main(java.lang.String[] args)
int	nidx(H2ONode h2o)
static void	notifyAboutCloudSize(java.net.InetAddress ip, int port, int size) Tell the embedding software that this H2O instance belongs to a cloud of a certain size.
static java.util.List<H2O.FlatFileEntry>	parseFlatFile(java.io.File f)
static java.util.List<H2O.FlatFileEntry>	parseFlatFile(java.io.InputStream is)
static java.util.HashSet<H2ONode>	parseFlatFileFromString(java.lang.String s)
static void	printAndLogVersion() If logging has not been setup yet, then Log.info will only print to stdout.
static void	printHelp()
static Value	putIfAbsent_raw(Key key, Value val)
static Value	putIfMatch(Key key, Value val, Value old)
static Value	raw_get(Key key)
static <T extends java.lang.Throwable> T	setDetailMessage(T t, java.lang.String s)
static void	setEmbeddedH2OConfig(AbstractEmbeddedH2OConfig c) Register embedded H2O configuration object with H2O instance.
void	shutdown() Shutdown itself by sending a shutdown UDP packet.
int	size()
static int	store_size()
static H2O.H2OCountedCompleter	submitTask(H2O.H2OCountedCompleter task)
java.lang.String	toPrettyString()
java.lang.String	toString()
static java.lang.RuntimeException	unimpl()
static java.util.Collection<Value>	values()
static void	waitForCloudSize(int x)
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

embeddedH2OConfig

public static volatile AbstractEmbeddedH2OConfig embeddedH2OConfig

apiIpPortWatchdog

public static volatile H2O.ApiIpPortWatchdogThread apiIpPortWatchdog

licenseManager

public static volatile LicenseManager licenseManager

VERSION

public static java.lang.String VERSION

START_TIME_MILLIS

public static long START_TIME_MILLIS

NAME

public static java.lang.String NAME

DEFAULT_PORT

public static int DEFAULT_PORT

UDP_PORT

public static int UDP_PORT

API_PORT

public static int API_PORT

SELF

public static H2ONode SELF

SELF_ADDRESS

public static java.net.InetAddress SELF_ADDRESS

ICE_ROOT

public static java.net.URI ICE_ROOT

ARGS

public static java.lang.String[] ARGS

OUT

public static final java.io.PrintStream OUT

ERR

public static final java.io.PrintStream ERR

NUMCPUS

public static final int NUMCPUS

CLOUD

public static volatile H2O CLOUD

_memary

public final H2ONode[] _memary

_hash

public final int _hash

_idx

public final char _idx

STATIC_H2OS

public static java.util.HashSet<H2ONode> STATIC_H2OS

DEBUG_ARG

public static final java.lang.String DEBUG_ARG

See Also:

Constant Field Values

DEBUG

public static final boolean DEBUG

VOLATILE

public static volatile int VOLATILE

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

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

ARY_KEY_PRIORITY

public static final byte ARY_KEY_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

OPT_ARGS

public static H2O.OptArgs OPT_ARGS

IS_SYSTEM_RUNNING

public static boolean IS_SYSTEM_RUNNING

DEFAULT_CREDENTIALS_LOCATION

public static final java.lang.String DEFAULT_CREDENTIALS_LOCATION

See Also:

Constant Field Values

_udpSocket

public static java.nio.channels.DatagramChannel _udpSocket

_apiSocket

public static java.net.ServerSocket _apiSocket

Constructor Detail

H2O

public H2O(H2ONode[] h2os,
   int hash,
   int idx)

Method Detail

DEFAULT_ICE_ROOT

public static java.lang.String DEFAULT_ICE_ROOT()

unimpl

public static java.lang.RuntimeException unimpl()

fail

public static java.lang.RuntimeException fail()

ignore

public static void ignore(java.lang.Throwable e)

ignore

public static void ignore(java.lang.Throwable e,
          java.lang.String msg)

ignore

public static void ignore(java.lang.Throwable e,
          java.lang.String msg,
          boolean printException)

setEmbeddedH2OConfig

public static void setEmbeddedH2OConfig(AbstractEmbeddedH2OConfig c)

Register embedded H2O configuration object with H2O instance.

getEmbeddedH2OConfig

public static AbstractEmbeddedH2OConfig getEmbeddedH2OConfig()

notifyAboutCloudSize

public static void notifyAboutCloudSize(java.net.InetAddress ip,
                        int port,
                        int size)

Tell the embedding software that this H2O instance belongs to a cloud of a certain size. This may be nonblocking.

Parameters:

ip - IP address this H2O can be reached at.

port - Port this H2O can be reached at (for REST API and browser).

size - Number of H2O instances in the cloud.

exit

public static void exit(int status)

Notify embedding software instance H2O wants to exit.

Parameters:

status - H2O's requested process exit value.

shutdown

public void shutdown()

Shutdown itself by sending a shutdown UDP packet.

larger

public static boolean larger(int nnn,
             int old)

isHealthy

public static boolean isHealthy()

size

public final int size()

leader

public final H2ONode leader()

waitForCloudSize

public static void waitForCloudSize(int x)

waitForCloudSize

public static void waitForCloudSize(int x,
                    long ms)

D

public int D(Key key,
    int repl)

nidx

public int nidx(H2ONode h2o)

contains

public boolean contains(H2ONode h2o)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

toPrettyString

public java.lang.String toPrettyString()

calcPrioritizedInetAddressList

public static java.util.ArrayList<java.net.InetAddress> calcPrioritizedInetAddressList()

Return a list of internet addresses sorted by importance (most important first). This is the order we want to test for matches when selecting an internet address.

findInetAddressForSelf

public static java.net.InetAddress findInetAddressForSelf()
                                                   throws java.lang.Error

Throws:

java.lang.Error

putIfMatch

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

putIfAbsent_raw

public static final Value putIfAbsent_raw(Key key,
                    Value val)

get

public static Value get(Key key)

raw_get

public static Value raw_get(Key key)

getk

public static Key getk(Key key)

localKeySet

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

values

public static java.util.Collection<Value> values()

store_size

public static int store_size()

globalKeySet

public static java.util.Set<Key> globalKeySet(java.lang.String clzname)

submitTask

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

printHelp

public static void printHelp()

getBuildVersion

public static AbstractBuildVersion getBuildVersion()

Load a h2o build version or return default unknown version

Returns:

never returns null

printAndLogVersion

public static void printAndLogVersion()

If logging has not been setup yet, then Log.info will only print to stdout. This allows for early processing of the '-version' option without unpacking the jar file and other startup stuff.

getVersion

public static java.lang.String getVersion()

main

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

getAWSCredentials

public static com.amazonaws.auth.PropertiesCredentials getAWSCredentials()
                                                                  throws java.io.IOException

Throws:

java.io.IOException

setDetailMessage

public static <T extends java.lang.Throwable> T setDetailMessage(T t,
                                                 java.lang.String s)

parseFlatFileFromString

public static java.util.HashSet<H2ONode> parseFlatFileFromString(java.lang.String s)

parseFlatFile

public static java.util.List<H2O.FlatFileEntry> parseFlatFile(java.io.File f)

parseFlatFile

public static java.util.List<H2O.FlatFileEntry> parseFlatFile(java.io.InputStream is)

localEntrySet

public static H2O.KeyInfo[] localEntrySet(H2O.KVFilter f,
                          boolean homeOnly,
                          boolean userOnly)

globalKeySet

public static H2O.KeyInfo[] globalKeySet(H2O.KVFilter f,
                         long timeTolerance)