|
|||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | ||||||||
See:
Description
| Interface Summary | |
|---|---|
| ExternalInterface | External interface for H2O. |
| Freezable | Empty marker interface. |
| Job.Progress | |
| Job.ProgressMonitor | |
| Class Summary | |
|---|---|
| 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 & 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. |
| Futures | A collection of Futures. |
| H2O | Start point for creating or joining an H2O Cloud. |
| H2O.ApiIpPortWatchdogThread | |
| H2O.Cleaner | |
| H2O.Cleaner.Histo | |
| H2O.FlatFileEntry | |
| H2O.H2OCallback<T extends H2O.H2OCountedCompleter> | |
| H2O.H2OCountedCompleter | |
| H2O.H2OEmptyCompleter | |
| 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 | |
| Job.Fail | |
| Job.FrameJob | |
| Job.HexJob | |
| Job.ModelJob | |
| Job.ValidatedJob | |
| Key | Keys This class defines: - A Key's bytes (name) & hash - Known Disk & memory replicas. |
| Key.Ary | |
| MemoryManager | Manages memory assigned to key/value pairs. |
| Model | A Model models reality (hopefully). |
| Model.SB | |
| 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 | |
| TaskGetKey | Get the given key from the remote node |
| TaskInvalidateKey | |
| TaskPutKey | Push the given key to the remote node |
| 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. |
| Value | The core Value stored in the distributed K/V store. |
| ValueArray | Large Arrays & 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 Summary | |
|---|---|
| Job.ChunkProgress.Status | |
| Request2.MultiVecSelectType | Specify how a column specifier field is parsed. |
| UDP.udp | |
| UDPRebooted.T | |
| Exception Summary | |
|---|---|
| AutoBuffer.TCPIsUnreliableException | |
| DException.DistributedException | |
| Error Summary | |
|---|---|
| Arguments.MissingArgumentError | |
The water package contains the implementation of H2O's core.
|
|||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | ||||||||