|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).
Created by tomas on 4/25/16.
Helps you avoid wrapping an exception into RTE.
|Atomic<T extends Atomic>||
Atomic update of a Key
A ByteBuffer backed mixed Input/Output streaming class, using Iced serialization.
Helper to provide access to package hidden methods and attributes.
A Distributed Key/Value Store.
Clears keys in all H2O nodes, except for the ones marked as retained.
|DTask<T extends DTask>||
Objects which are passed and
|DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>||
Task to be executed at the home node of the given key.
Task to cleanly remove value from the K/V (call it's remove() destructor) without the need to fetch it locally first.
A class used for checking whether read/write operation in external cluster finished within specified timeout
This class is used to read data from H2O Frames from non-H2O environments, such as Spark Executors.
Various utilities methods to help with external frame handling.
This class is used to create and write data to H2O Frames from non-H2O environments, such as Spark Executors.
Extension used for checking failed nodes
A collection of Futures that can be extended, or blocked on the whole collection.
Start point for creating or joining an
A class containing all of the authentication arguments for H2O.
|H2O.H2OCallback<T extends H2O.H2OCountedCompleter>|
|H2O.H2OCountedCompleter<T extends H2O.H2OCountedCompleter>||
Simple wrapper over F/J
A class containing all of the arguments for H2O.
|H2O.RemoteRunnable<T extends H2O.RemoteRunnable>|
Global constants used throughout the H2O-3 project.
Class which represents a back-end error which will be returned to the client.
Class which represents a ModelBuilder back-end error which will be returned to the client.
Takes care of security.
H2O starter which manages start and registration of application extensions.
Struct holding H2ONode health info.
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.
Utility class to support Iced objects.
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
|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.
Convenience class for easy access to user-visible keys in the cloud with enabled caching.
Class containing information about user keys.
Class to filter keys from the snapshot.
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
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>>|
(Not The) Paxos Used to define Cloud membership.
|RPC<V extends DTask>||
A remotely executed FutureTask.
A "scope" for tracking Key lifetimes; an experimental API.
Get the given key from the remote node
Push the given key to the remote node
|TAtomic<T extends Freezable>||
A typed atomic update.
The Thread that looks for TCP Cloud requests.
Maintain a VERY efficient list of events in the system.
Internal H2O class used to build and maintain the cloud-wide type mapping.
Do Something with an incoming UDP packet Classic Single Abstract Method pattern.
A simple message which informs cluster about a new client which was connected or about existing client who wants to disconnect.
A UDP Rebooted packet: this node recently rebooted
The core Value stored in the distributed K/V store, used to cache Plain Old Java Objects, and maintain coherency around the cluster.
Class to auto-gen serializer delegate classes.
UDP packet types, and their handlers
Exception used for reporting failure during write/read confirmation in external mode