See: Description
| Interface | Description |
|---|---|
| BootstrapFreezable<T extends BootstrapFreezable<T>> |
Marker interface - can be used to annotate Freezables that are part of bootstrap class collection.
|
| 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).
|
| H2OListenerExtension | |
| TypeMapExtension |
Allows to dynamically modify behavior of TypeMap
|
| Class | Description |
|---|---|
| AbstractH2OExtension | |
| 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.
|
| ClientRandomDisconnectThread | |
| DKV |
A Distributed Key/Value Store.
|
| DKVManager | |
| 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.
|
| ExtensionManager | |
| FrameSizeMonitor | |
| 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.H2OCallback<T extends H2O.H2OCountedCompleter> | |
| H2O.H2OCountedCompleter<T extends H2O.H2OCountedCompleter> |
Simple wrapper over F/J
CountedCompleter to support priority
queues. |
| H2O.KeyValueArg | |
| H2O.OptArgs |
A class containing all of the arguments for H2O.
|
| H2O.OptString | |
| H2O.RemoteRunnable<T extends H2O.RemoteRunnable> | |
| H2OConstants |
Global constants used throughout the H2O-3 project.
|
| 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. |
| H2ONodeTimestamp | |
| H2ORuntime |
H2O wrapper around Runtime class exposing modified versions of some functions
|
| 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. |
| JavaSelfCheck | |
| JavaVersionSupport | |
| 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.
|
| JobUpdatePostMap | |
| 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.
|
| ListenerService |
Service used to write to registered H2O listeners
|
| 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.
|
| MRTask.PostMapAction<T extends MRTask.PostMapAction<T>> | |
| ParallelizationTask<T extends H2O.H2OCountedCompleter<T>> | |
| Paxos |
(Not The) Paxos
Used to define Cloud membership.
|
| RestApiPingCheckThread | |
| 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 | |
| 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.JobStatus | |
| UDP.udp |
UDP packet types, and their handlers
|
| UDPRebooted.T |
| Exception | Description |
|---|---|
| AutoBuffer.AutoBufferException | |
| Job.JobCancelledException |