| Interface | Description |
|---|---|
| ExternalInterface |
External interface for H2O.
|
| Freezable |
Empty marker interface.
|
| Job.Progress | |
| Job.ProgressMonitor |
| Class | Description |
|---|---|
| AbstractBuildVersion | |
| AbstractEmbeddedH2OConfig |
This class is a small shim between a main java program (such as a
Hadoop mapper) and an embedded full-capability H2O.
|
| Arguments |
Utility for processing command
Simple command line processing.
|
| Arguments.Arg | |
| Arguments.Opt |
Optional arguments.
|
| Arguments.Req |
Required arguments.
|
| Atomic<T extends Atomic> |
Atomic update of a Key
|
| AutoBuffer |
A ByteBuffer backed mixed Input/OutputStream class.
|
| BitsCmpTask | |
| Boot |
Initializer class for H2O.
|
| BuildVersion | |
| DException |
A Distributed Exception - an exception originally thrown on one node
and passed to another.
|
| DKV |
Distributed Key/Value Store
This class handles the distribution pattern.
|
| DRemoteTask<T extends DRemoteTask> |
A Distributed DTask.
|
| DTask<T extends DTask> |
Objects which are passed and remotely executed.
|
| External |
Expose internal H2O API calls to the External World
H2O innards need to go through the H2O ClassLoader to get bytecode
reweaving done - e.g.
|
| FetchClazz | |
| FetchId | |
| FJPacket |
A class to handle the work of a received UDP packet.
|
| Func |
Short-time computation which is not a job.
|
| Futures |
A collection of Futures.
|
| H2O |
Start point for creating or joining an
H2O Cloud. |
| H2O.ApiIpPortWatchdogThread | |
| H2O.Cleaner | |
| H2O.Cleaner.Histo | |
| H2O.FJWThr | |
| H2O.FlatFileEntry | |
| H2O.H2OCallback<T extends H2O.H2OCountedCompleter> | |
| H2O.H2OCountedCompleter | |
| H2O.H2OEmptyCompleter | |
| H2O.KeyInfo | |
| H2O.KVFilter | |
| H2O.OptArgs | |
| H2ONode |
A
Node in an H2O Cloud. |
| H2ONode.AckAckTimeOutThread | |
| 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 |
Empty marker class.
|
| InternalInterface | |
| Job | |
| Job.ChunkProgress | |
| Job.ChunkProgressJob | |
| Job.ColumnsJob |
A job which has an input represented by a frame and frame column filter.
|
| Job.ColumnsResJob |
A columns job that requires a response.
|
| Job.Fail | |
| Job.FrameJob |
A job which operates with a frame.
|
| Job.HexJob | |
| Job.List | |
| Job.ModelJob |
A job producing a model.
|
| Job.ModelJobWithoutClassificationField |
A job producing a model that has no notion of Classification or Regression.
|
| Job.ValidatedJob |
Job which produces model and validate it on a given dataset.
|
| Key |
Keys
This class defines:
- A Key's bytes (name) and hash
- Known Disk and memory replicas.
|
| Key.Ary | |
| Lockable<T extends Lockable<T>> |
Lockable Keys - locked during long running jobs, to prevent overwriting
in-use keys.
|
| MemoryManager |
Manages memory assigned to key/value pairs.
|
| Model |
A Model models reality (hopefully).
|
| ModelMetrics |
Container to hold the metric for a model as scored on a specific frame.
|
| MRTask<T extends MRTask> |
Map/Reduce style distributed computation.
|
| MRTask2<T extends MRTask2<T>> |
Map/Reduce style distributed computation.
|
| MultiReceiverThread |
The Thread that looks for Multicast UDP Cloud requests.
|
| NanoHTTPD |
A simple, tiny, nicely embeddable HTTP 1.0 (partially 1.1) server in Java
|
| NOPTask | |
| OldModel |
A Model models reality (hopefully).
|
| Paxos |
(Not The) Paxos
Used to define Cloud membership.
|
| PrettyPrint | |
| Request2 | |
| RPC<V extends DTask> |
A remotely executed FutureTask.
|
| RPC.RemoteHandler | |
| RPC.RPCCall | |
| RReader | |
| Scope | |
| TaskGetKey |
Get the given key from the remote node
|
| TaskInvalidateKey | |
| TaskPutKey |
Push the given key to the remote node
|
| TaskSendKey |
Send a Key from its home node to some remote node via a "push"
|
| TAtomic<T extends Iced> |
A typed atomic update.
|
| TCPReceiverThread |
The Thread that looks for TCP Cloud requests.
|
| TCPReceiverThread.TCPReaderThread | |
| TimeLine |
Maintain a VERY efficient list of events in the system.
|
| Timer |
Simple Timer class.
|
| TypeMap | |
| UDP |
Do Something with an incoming UDP packet
Classic Single Abstract Method pattern.
|
| UDPAck |
A remote task request has just returned an ACK with answer
|
| UDPAckAck |
A task initiator has his response, we can quit sending him ACKs.
|
| UDPBrokenPacket |
An unexpected UDP packet
|
| UDPHeartbeat |
A UDP Heartbeat packet.
|
| UDPRebooted |
A UDP Rebooted packet: this node recently rebooted
|
| UDPReceiverThread |
The Thread that looks for UDP Cloud requests.
|
| UDPTimeOutThread |
The Thread that looks for UDPAsyncTasks that are timing out
|
| UKV |
User-View Key/Value Store
This class handles user-view keys, and hides ArrayLets from the end user.
|
| UniqueFrameId |
Frames are mutable, so we can't create a unique id at creation time to distinguish
between Frames.
|
| UniqueId |
Some properties to mix in to Frame, Model and such to make them uniquely identifyable.
|
| Value |
The core Value stored in the distributed K/V store.
|
| ValueArray |
Large Arrays and Arraylets
Large arrays are broken into 4Meg chunks (except the last chunk which may be
from 4 to 8Megs).
|
| ValueArray.Column | |
| ValueArray.CsvVAStream | |
| ValueArray.VAStream | |
| Weaver |
| Enum | Description |
|---|---|
| Job.ChunkProgress.Status | |
| Job.JobState |
Possible job states.
|
| Model.ModelCategory | |
| Request2.MultiVecSelectType |
Specify how a column specifier field is parsed.
|
| UDP.udp | |
| UDPRebooted.T |
| Exception | Description |
|---|---|
| AutoBuffer.TCPIsUnreliableException | |
| DException.DistributedException | |
| Job.JobCancelledException |
| Error | Description |
|---|---|
| Arguments.MissingArgumentError |