See: Description
| 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 | Description |
|---|---|
| Atomic<T extends Atomic> |
Atomic update of a Key
|
| AutoBuffer |
A ByteBuffer backed mixed Input/OutputStream class.
|
| AutoBufferWithoutTypeIds |
Simple wrapper around
AutoBuffer
which uses class names instead of type ids. |
| ChunkSplitter |
Helper to provide access to package
hidden methods and attributes.
|
| DException |
A Distributed Exception - an exception originally thrown on one node
and passed to another.
|
| 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.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.
|
| H2OClient |
A simple wrapper around H2O starter to launch H2O in client mode.
|
| 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. |
| H2ONode.H2Okey | |
| 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.
|
| 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. |
| 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.
|
| Job.Progress |
Helper class to store the job progress in the DKV
|
| Job.ProgressUpdate |
Helper class to atomically update the job progress in the DKV
|
| 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.
|
| Keyed.BinarySerializer<X extends Keyed> | |
| 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.
|
| NanoHTTPD |
A simple, tiny, nicely embeddable HTTP 1.0 (partially 1.1) server in Java
|
| 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.
|
| 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 | Description |
|---|---|
| Job.JobState |
Possible job states.
|
| UDP.udp |
UDP packet types, and their handlers
|
| Exception | Description |
|---|---|
| DException.DistributedException |
Simple named exception class, inflated from a deserialized
DException. |
| Job.JobCancelledException |
Simple named exception class
|