| Interface | Description |
|---|---|
| Freezable |
Auto-serializer base-class using a delegator pattern.
|
| Class | Description |
|---|---|
| Atomic<T extends Atomic> |
Atomic update of a Key
|
| AutoBuffer |
A ByteBuffer backed mixed Input/OutputStream class.
|
| ConfusionMatrix2 | |
| 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.
|
| DTask<T extends DTask> |
Objects which are passed and remotely executed.
|
| FetchClazz | |
| FetchId | |
| Futures |
A collection of Futures.
|
| H2O |
Start point for creating or joining an
H2O Cloud. |
| H2O.H2OCountedCompleter<T extends H2O.H2OCountedCompleter> | |
| H2O.OptArgs | |
| H2ONode |
A
Node in an H2O Cloud. |
| 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> |
Auto-serializer base-class using a delegator pattern.
|
| Icer<T extends Freezable> | |
| Job<T extends Keyed> |
Jobs are Keyed, because they need to Key to control e.g.
|
| Key |
Keys
This class defines:
- A Key's bytes (name) & hash
- Known Disk & memory replicas.
|
| 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 - locked during long running jobs, to prevent overwriting
in-use keys.
|
| MemoryManager |
Manages memory assigned to key/value pairs.
|
| Model<M extends Model<M,P,O>,P extends Model.Parameters<M,P,O>,O extends Model.Output<M,P,O>> |
A Model models reality (hopefully).
|
| Model.Output<M extends Model<M,P,O>,P extends Model.Parameters<M,P,O>,O extends Model.Output<M,P,O>> |
Model-specific output class.
|
| Model.Parameters<M extends Model<M,P,O>,P extends Model.Parameters<M,P,O>,O extends Model.Output<M,P,O>> |
Model-specific parameter class.
|
| 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 | |
| SupervisedModel<M extends Model<M,P,O>,P extends Model.Parameters<M,P,O>,O extends Model.Output<M,P,O>> |
Supervised Model
There is a response column used in training.
|
| 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.
|
| TCPReceiverThread.TCPReaderThread | |
| TimeLine |
Maintain a VERY efficient list of events in the system.
|
| TypeMap | |
| 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 UDPAsyncTasks that are timing out
|
| Value |
The core Value stored in the distributed K/V store.
|
| VarImp | |
| VarImp.VarImpMDA |
Variable importance measured as mean decrease in accuracy.
|
| VarImp.VarImpRI |
Variable importance measured as relative influence.
|
| Weaver |
| Enum | Description |
|---|---|
| ConfusionMatrix2.ErrMetric | |
| Job.JobState |
Possible job states.
|
| Model.ModelCategory | |
| UDP.udp |
| Exception | Description |
|---|---|
| DException.DistributedException |