Package ca.uqac.lif.cep.tmf

Processors to manipulate traces of generic events. More...

Classes
class	AbstractSlice
	Separates an input trace into different "slices". More...
class	AbstractWindow
	Simulates the application of a "sliding window" to a trace. More...
class	BlackHole
	A special type of Sink that discards everything it receives. More...
class	CallbackSink
	A sink that calls a method when a new front of events is pushed to it. More...
class	CountDecimate
	Returns one input event and discards the next n-1. More...
class	Decimate
	By default, a Decimate acts like a Passthrough for which only certain inputs are allowed to be output. More...
class	Divert
	Diverts an input stream to one of many downstream processor chains. More...
class	Filter
	Discards events from an input trace based on a selection criterion. More...
class	FilterOn
	Discards events from an input trace based on a selection criterion. More...
class	Fork
	Duplicates an input trace into two or more output traces. More...
class	Freeze
	Repeatedly outputs the first event it has received. More...
class	Insert
	Inserts an event a certain number of times before letting the input events through. More...
class	KeepLast
	Outputs only the last event received. More...
class	Multiplex
	Merges the contents of multiple traces into a single trace. More...
class	Pad
class	Passthrough
	Returns its input as its output. More...
class	Prefix
	Returns the first n input events and discards the following ones. More...
class	Pump
	Processor that repeatedly pulls its input, and pushes the resulting events to its output. More...
class	QueueSink
	Sink that accumulates events into queues. More...
class	QueueSource
	Source whose input is a queue of objects. More...
class	QueueSourceBatch
	Operates like QueueSource, except that it dumps all its queue at once, instead of releasing the events one by one. More...
class	ResetLast
	Processor that receives two input streams; it pushes the events of a first stream into a processor, and resets this processor whenever the event on the second input stream is true. More...
class	SimpleFilter
	A simple filter that lets input events out by evaluating a condition on them; if the condition evaluates to true, the event is output, otherwise it is discarded. More...
class	Sink
	Receives input events and stores them. More...
class	SinkLast
	Sink that remembers only the last event sent to it. More...
class	Slice
	Concrete version of AbstractSlice whose output is an associative map between slice IDs and the last event produced by that slice processor. More...
class	SliceLast
	Concrete version of AbstractSlice whose output is a stream of lists, where each list contains all the events produced by inner slices from a given input even. More...
class	Source
	Produces output events from no input. More...
class	Splice
	Joins multiple sources as a single one. More...
class	Stutter
	Repeats each input event a specified number of times. More...
class	Tank
	Accumulates pushed events into a queue until they are pulled. More...
class	TankLast
	Tank that, when pulled, creates an output event based on the last event received. More...
class	TimeDecimate
	After returning an input event, discards all others for the next n seconds. More...
class	Trim
	Discards the first n events of the input, and outputs the remaining ones. More...
class	VariableStutter
	Processor that repeats input events a number of times based on a control signal. More...
class	Window
	Simulates the application of a "sliding window" to a trace. More...
class	WindowFunction
	Takes a sliding window of n successive input events, passes them to an n-ary function and outputs the result. More...

Detailed Description

Processors to manipulate traces of generic events.

This includes delaying, discarding, filtering, freezing, multiplexing and demultiplexing, and applying a sliding window, among other things.

Author

Sylvain Hallé