Package water

Core H2O classes; including Clustering, Management, Distributed K/V Store, RPC and Map/Reduce tasks.

See: Description

Interface Summary

Interface	Description
Freezable<T extends Freezable>	Auto-serializer interface using a delegator pattern (the faster option is to byte-code gen directly in all Iced classes, but this requires all Iced classes go through a ClassLoader).

Class Summary

Class	Description
AbstractH2OExtension
AbstractKey	Created by tomas on 4/25/16.
Atomic<T extends Atomic>	Atomic update of a Key
AutoBuffer	A ByteBuffer backed mixed Input/Output streaming class, using Iced serialization.
ChunkSplitter	Helper to provide access to package hidden methods and attributes.
DKV	A Distributed Key/Value Store.
DTask<T extends DTask>	Objects which are passed and DTask.dinvoke(water.H2ONode) is remotely executed.
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>	Task to be executed at the home node of the given key.
DTask.RemoveCall	Task to cleanly remove value from the K/V (call it's remove() destructor) without the need to fetch it locally first.
Futures	A collection of Futures that can be extended, or blocked on the whole collection.
H2O	Start point for creating or joining an H2O Cloud.
H2O.AboutEntry
H2O.FJWThr
H2O.GAStartupReportThread
H2O.H2OCallback<T extends H2O.H2OCountedCompleter>
H2O.H2OCountedCompleter<T extends H2O.H2OCountedCompleter>	Simple wrapper over F/J CountedCompleter to support priority queues.
H2O.H2OFuture<T>
H2O.OptArgs	A class containing all of the arguments for H2O.
H2O.OptString
H2OError	Class which represents a back-end error which will be returned to the client.
H2OModelBuilderError	Class which represents a ModelBuilder back-end error which will be returned to the client.
H2ONode	A Node in an H2O Cloud.
H2OStarter	H2O starter which manages start and registration of application extensions.
HeartBeat	Struct holding H2ONode health info.
HeartBeatThread	Starts a thread publishing multicast HeartBeats to the local subnet: the Leader of this Cloud.
Iced<D extends Iced>	H2O uses Iced classes as the primary means of moving Java Objects around the cluster.
IcedUtils	Utility class to support Iced objects.
IcedWrapper	Iced wrapper object for primitive types and arrays, to allow fields in other Iced classes to have a generic type equivalent to Object, which can contain primitives, arrays, and Iced objects.
Icer<T extends Freezable>	Base Class for the Iced implementation hierarchy; subclasses are all auto-gen'd and no user code should call or extend this class.
JettyHTTPD	Embedded Jetty instance inside H2O.
Job<T extends Keyed>	Jobs are used to do minimal tracking of long-lifetime user actions, including progress-bar updates and the ability to review in progress or completed Jobs, and cancel currently running Jobs.
Key<T extends Keyed>	Keys! H2O supports a distributed Key/Value store, with exact Java Memory Model consistency.
Keyed<T extends Keyed>	Iced, with a Key.
KeySnapshot	Convenience class for easy access to user-visible keys in the cloud with enabled caching.
KeySnapshot.KeyInfo	Class containing information about user keys.
KeySnapshot.KVFilter	Class to filter keys from the snapshot.
Lockable<T extends Lockable<T>>	Lockable Keys - Keys locked during long running Jobs, to prevent overwriting in-use keys.
MemoryManager	Manages memory assigned to key/value pairs.
MRTask<T extends MRTask<T>>	Map/Reduce style distributed computation.
Paxos	(Not The) Paxos Used to define Cloud membership.
RPC<V extends DTask>	A remotely executed FutureTask.
Scope	A "scope" for tracking Key lifetimes; an experimental API.
TaskGetKey	Get the given key from the remote node
TaskPutKey	Push the given key to the remote node
TAtomic<T extends Freezable>	A typed atomic update.
TCPReceiverThread	The Thread that looks for TCP Cloud requests.
TimeLine	Maintain a VERY efficient list of events in the system.
TypeMap	Internal H2O class used to build and maintain the cloud-wide type mapping.
UDP	Do Something with an incoming UDP packet Classic Single Abstract Method pattern.
UDPRebooted	A UDP Rebooted packet: this node recently rebooted
UDPRebooted.ShutdownTsk
UDPReceiverThread	The Thread that looks for UDP Cloud requests.
UDPTimeOutThread	The Thread that looks for RPCs that are timing out
Value	The core Value stored in the distributed K/V store, used to cache Plain Old Java Objects, and maintain coherency around the cluster.
Weaver	Class to auto-gen serializer delegate classes.

Enum Summary

Enum	Description
UDP.udp	UDP packet types, and their handlers
UDPRebooted.T

Exception Summary

Exception	Description
AutoBuffer.AutoBufferException
Job.JobCancelledException

Package water Description

Core H2O classes; including Clustering, Management, Distributed K/V Store, RPC and Map/Reduce tasks.