 |
0.11.4
|
|
0.11.4
|
Elementary classes defining all the basic concepts of event stream processing.
Here are some of the important objects defined in this package.
Processor is an object that takes zero or more event streams, and produces zero or more event streams as its output. - Pullable and Pushable are two interfaces for receiving and giving events from/to a processor, respectively. - Connector provides static methods for easily linking one processor's output to another's inputPackages | |
| package | functions |
Definition of the Function object and basic concepts around functions. | |
| package | io |
| Processors to handle input and output of data from external sources, such as files and pipes. | |
| package | tmf |
| Processors to manipulate traces of generic events. | |
| package | util |
| Utility processors and functions to manipulate strings, arrays, and a few other data structures. | |
Classes | |
| class | Adder |
| A simple processor that adds two integers. More... | |
| class | AsynchronousProcessor |
| Processor that handles its inputs asynchronously. More... | |
| interface | CallAfterConnect |
An object carrying a Processor to be connected, and which expects a call to its call() method after the connection is established. More... | |
| class | Connector |
| Provides a number of convenient methods for connecting the outputs of processors to the inputs of other processors. More... | |
| class | Context |
| Associative map used by processors to store persistent data. More... | |
| interface | Contextualizable |
Interface implemented by all BeepBeep objects that manipulate a Context. More... | |
| class | Doubler |
| A processor that doubles every number it is given. More... | |
| interface | Duplicable |
| Interface indicating that an object can be duplicated. More... | |
| interface | DuplicableProcessor |
An override on the return type of Duplicable that enforces the return of a processor. More... | |
| interface | EventNodeFunction |
| interface | EventTracker |
| Tracks the relationship between output events produced by processors, and the input events that were used to compute them. More... | |
| class | GroupProcessor |
| Encapsulates a chain of processors as if it were a single one. More... | |
| class | Main |
| A dummy main file defining a few system-wide constants. More... | |
| class | PipeCrawler |
| An object that visits every processor in a chain, from a processor used as a starting point. More... | |
| class | Processor |
| Receives zero or more input events, and produces zero or more output events. More... | |
| class | ProcessorException |
| Generic class for any exception thrown in the lifecycle of a processor. More... | |
| interface | Pullable |
| Queries events on one of a processor's outputs. More... | |
| interface | Pushable |
| Gives events to some of a processor's input. More... | |
| interface | Stateful |
| Interface implemented by processors that can publicly expose a token equivalent to their internal state. More... | |
| class | SynchronousProcessor |
| Performs a computation on input events to produce output events. More... | |
| class | TypedPullable |
| A Pullable object that casts all its output to a given type. More... | |
| class | UniformProcessor |
| Processor that produces exactly one output front for each input front received. More... | |
| class | UtilityMethods |
| A few methods repeatedly used throughout the code repository examples. More... | |
1.15.0