|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
See:
Description
Interface Summary | |
---|---|
Streamable<T extends Event> | We use this interface to put events into objects. |
Class Summary | |
---|---|
App | Container base class to hold all processing elements. |
DefaultCoreModule | Temporary module allowing assignment from ZK, communication through Netty, and distributed deployment management, until we have a better way to customize node configuration |
Key<T extends Event> | The Key class is used to get the value of the key on a specific type of event. |
Main | Bootstrap class for S4. |
Main.InlineConfigParameterConverter | Parameters parsing utility. |
Main.MainArgs | Defines command parameters. |
ProcessingElement | Base class for implementing processing in S4. |
Receiver | The Receiver and its counterpart Sender are the top level classes of the communication layer. |
RemoteSender | Sends events to a remote cluster. |
RemoteSenders | Sends events to remote clusters. |
RemoteStream | Stream that dispatches events to interested apps in remote clusters |
Sender | The Sender and its counterpart Receiver are the top level classes of the communication layer. |
Server | The Server instance coordinates activities in a cluster node including loading and unloading of applications and instantiating the communication layer. |
Stream<T extends Event> | Stream and ProcessingElement objects represent the links and nodes in the application graph. |
Enum Summary | |
---|---|
App.ClockType | The internal clock can be configured as "wall clock" or "event clock". |
Key classes of the S4 platform, implementing concepts such as Stream, Processing Element.
|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |