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 |
|---|---|
| AbstractH2OExtension | |
| AbstractHTTPD | |
| AbstractKey |
Created by tomas on 4/25/16.
|
| AnyThrow |
Helps you avoid wrapping an exception into RTE.
|
| 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.
|
| ExternalFrameConfirmationCheck |
A class used for checking whether read/write operation in external cluster finished within specified timeout
|
| ExternalFrameReaderClient |
This class is used to read data from H2O Frames from non-H2O environments, such as Spark Executors.
|
| ExternalFrameUtils |
Various utilities methods to help with external frame handling.
|
| ExternalFrameWriterClient |
This class is used to create and write data to H2O Frames from non-H2O environments, such as Spark Executors.
|
| FailedNodeWatchdogExtension |
Extension used for checking failed nodes
|
| 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.BaseArgs |
A class containing all of the authentication arguments for H2O.
|
| 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. |
| H2OSecurityManager |
Takes care of security.
|
| 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.
|
| LocalMR<T extends MrFun<T>> |
Created by tomas on 11/5/16.
|
| 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.
|
| MrFun<T extends MrFun<T>> |
Created by tomas on 11/5/16.
|
| MRTask<T extends MRTask<T>> |
Map/Reduce style distributed computation.
|
| ParallelizationTask<T extends H2O.H2OCountedCompleter<T>> | |
| 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.
|
| UDPClientEvent |
A simple message which informs cluster about a new client
which was connected or about existing client who wants to disconnect.
|
| UDPClientEvent.ClientEvent | |
| 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 | Description |
|---|---|
| UDP.udp |
UDP packet types, and their handlers
|
| UDPClientEvent.ClientEvent.Type | |
| UDPRebooted.T |
| Exception | Description |
|---|---|
| AutoBuffer.AutoBufferException | |
| ExternalFrameConfirmationException |
Exception used for reporting failure during write/read confirmation in external mode
|
| Job.JobCancelledException |