Package ca.uqac.lif.cep

Elementary classes defining all the basic concepts of event stream processing. More...

Packages
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...
class	CompoundFuture
	A Future object whose termination and output value depends on the termination and output values of multiple other Future objects. 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	FutureDone
	A Future object indicating that the computation is completed. 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...

Detailed Description

Elementary classes defining all the basic concepts of event stream processing.

Here are some of the important objects defined in this package.

• A 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 input

Author

Sylvain Hallé