Package org.apache.s4.core

Key classes of the S4 platform, implementing concepts such as Stream, Processing Element.

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".
 

Package org.apache.s4.core Description

Key classes of the S4 platform, implementing concepts such as Stream, Processing Element.