| CArrayList | |
| Cca.uqac.lif.cep.util.Lists.MathList< T > | A list that implements equality |
| Cca.uqac.lif.cep.util.Bags | A container object for functions and processors applying to generic collections, i.e |
| Cca.uqac.lif.cep.functions.ApplyFunctionLambda.BinaryLambdaEvaluable | |
| Cca.uqac.lif.cep.functions.FunctionLambda.BinaryLambdaEvaluable | |
| Cca.uqac.lif.cep.util.Booleans | A container object for Boolean functions |
| Cca.uqac.lif.cep.CallAfterConnect | An object carrying a Processor to be connected, and which expects a call to its call() method after the connection is established |
| Cca.uqac.lif.cep.GroupProcessor.OutputCallAfterConnect | A CallAfterConnect object that can be used to connect the underlying processor of a GroupProcessor, and then to collect all processors that are part of the group |
| Cca.uqac.lif.cep.Connector.Connection | Represents a connection between two pipes |
| Cca.uqac.lif.cep.Connector | Provides a number of convenient methods for connecting the outputs of processors to the inputs of other processors |
| Cca.uqac.lif.cep.Contextualizable | Interface implemented by all BeepBeep objects that manipulate a Context |
| Cca.uqac.lif.cep.Processor | Receives zero or more input events, and produces zero or more output events |
| Cca.uqac.lif.cep.AsynchronousProcessor | Processor that handles its inputs asynchronously |
| Cca.uqac.lif.cep.GroupProcessor | Encapsulates a chain of processors as if it were a single one |
| Cca.uqac.lif.cep.SynchronousProcessor | Performs a computation on input events to produce output events |
| Cca.uqac.lif.cep.Adder | A simple processor that adds two integers |
| Cca.uqac.lif.cep.Doubler | A processor that doubles every number it is given |
| Cca.uqac.lif.cep.UniformProcessor | Processor that produces exactly one output front for each input front received |
| Cca.uqac.lif.cep.functions.ApplyFunction | Applies a function to input events to produce output events |
| Cca.uqac.lif.cep.functions.Cumulate | Creates a cumulative processor out of a cumulative function |
| Cca.uqac.lif.cep.functions.ApplyFunctionLambda | |
| Cca.uqac.lif.cep.functions.Integrate | Receives a stream of Function objects and applies these functions to update an internal object kept in memory |
| Cca.uqac.lif.cep.functions.TurnInto | Processor that turns any event into a predefined object |
| Cca.uqac.lif.cep.io.Call | Processor calling an external command upon receiving an event, and returning the output of that command as its output stream |
| Cca.uqac.lif.cep.tmf.Fork | Duplicates an input trace into two or more output traces |
| Cca.uqac.lif.cep.tmf.Freeze | Repeatedly outputs the first event it has received |
| Cca.uqac.lif.cep.tmf.Passthrough | Returns its input as its output |
| Cca.uqac.lif.cep.util.Lists.ListUpdateProcessor | Processor that updates a list |
| Cca.uqac.lif.cep.util.Lists.PutInto | Updates a list |
| Cca.uqac.lif.cep.util.Lists.PutIntoNew | Updates a list |
| Cca.uqac.lif.cep.util.Maps.MapPutInto | Updates a map by putting key-value pairs into it |
| Cca.uqac.lif.cep.util.Maps.MergeMaps | Updates a map by merging its contents with a stream of incoming maps |
| Cca.uqac.lif.cep.util.Maps.PutInto | Updates a map by putting key-value pairs into it |
| Cca.uqac.lif.cep.util.Randomize | A n:n processor that turns an arbitrary input event front into an output front made of randomly selected numerical values |
| Cca.uqac.lif.cep.util.Sets.SetUpdateProcessor | Processor that updates a set |
| Cca.uqac.lif.cep.util.Sets.Intersect | Calculates the successive intersection of a stream of sets |
| Cca.uqac.lif.cep.util.Sets.PutInto | Updates a set by putting the elements it receives into the set |
| Cca.uqac.lif.cep.util.Sets.PutIntoNew | Updates a set |
| Cca.uqac.lif.cep.util.Sets.Union | Calculates the successive union of a stream of sets |
| Cca.uqac.lif.cep.util.Strings.BuildString | Concatenates input strings into an output string |
| Cca.uqac.lif.cep.tmf.AbstractSlice | Separates an input trace into different "slices" |
| Cca.uqac.lif.cep.tmf.Slice | Concrete version of AbstractSlice whose output is an associative map between slice IDs and the last event produced by that slice processor |
| Cca.uqac.lif.cep.tmf.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 event |
| Cca.uqac.lif.cep.tmf.AbstractWindow | Simulates the application of a "sliding window" to a trace |
| Cca.uqac.lif.cep.tmf.Window | Simulates the application of a "sliding window" to a trace |
| Cca.uqac.lif.cep.tmf.CallbackSink | A sink that calls a method when a new front of events is pushed to it |
| Cca.uqac.lif.cep.tmf.Decimate | By default, a Decimate acts like a Passthrough for which only certain inputs are allowed to be output |
| Cca.uqac.lif.cep.tmf.CountDecimate | Returns one input event and discards the next n-1 |
| Cca.uqac.lif.cep.tmf.TimeDecimate | After returning an input event, discards all others for the next n seconds |
| Cca.uqac.lif.cep.tmf.DetectEnd | Lets all input events through, and sends an "end of trace" signal when a specific event is received |
| Cca.uqac.lif.cep.tmf.Filter | Discards events from an input trace based on a selection criterion |
| Cca.uqac.lif.cep.tmf.FilterOn | Discards events from an input trace based on a selection criterion |
| Cca.uqac.lif.cep.tmf.Insert | Inserts an event a certain number of times before letting the input events through |
| Cca.uqac.lif.cep.tmf.KeepLast | Outputs only the last event received |
| Cca.uqac.lif.cep.tmf.Pad | |
| Cca.uqac.lif.cep.tmf.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 |
| Cca.uqac.lif.cep.tmf.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 |
| Cca.uqac.lif.cep.tmf.Sink | Receives input events and stores them |
| Cca.uqac.lif.cep.io.Print | Sends its input to a PrintStream (such as the standard output) |
| Cca.uqac.lif.cep.io.Print.Println | A special type of Print processor that prints a carriage return by default between tokens |
| Cca.uqac.lif.cep.io.WriteOutputStream | Processor that writes events to a Java OutputStream |
| Cca.uqac.lif.cep.io.WriteToFile | Writes input events to one or more files |
| Cca.uqac.lif.cep.tmf.BlackHole | A special type of Sink that discards everything it receives |
| Cca.uqac.lif.cep.tmf.QueueSink | Sink that accumulates events into queues |
| Cca.uqac.lif.cep.tmf.SinkLast | Sink that remembers only the last event sent to it |
| Cca.uqac.lif.cep.tmf.Source | Produces output events from no input |
| Cca.uqac.lif.cep.io.HttpGet | Reads chunks of data from an URL, using an HTTP request |
| Cca.uqac.lif.cep.io.ReadInputStream | Read contents from a Java InputStream, and outputs its chunks as byte arrays |
| Cca.uqac.lif.cep.io.ReadStringStream | Extracts character strings from a Java InputStream |
| Cca.uqac.lif.cep.io.ReadTokens | Separates a stream of string chunks into tokens according to a user-defined separator |
| Cca.uqac.lif.cep.io.ReadLines | Source that reads text lines from a Java InputStream |
| Cca.uqac.lif.cep.io.SpliceSource | Source that sequentially reads from multiple input files, and optionally from the standard input |
| Cca.uqac.lif.cep.io.SpliceSource.SpliceByteSource | |
| Cca.uqac.lif.cep.io.SpliceSource.SpliceLineSource | |
| Cca.uqac.lif.cep.io.SpliceSource.SpliceTokenSource | |
| Cca.uqac.lif.cep.tmf.QueueSource | Source whose input is a queue of objects |
| Cca.uqac.lif.cep.tmf.QueueSourceBatch | Operates like QueueSource, except that it dumps all its queue at once, instead of releasing the events one by one |
| Cca.uqac.lif.cep.tmf.Splice | Joins multiple sources as a single one |
| Cca.uqac.lif.cep.tmf.Stutter | Repeats each input event a specified number of times |
| Cca.uqac.lif.cep.tmf.Trim | Discards the first n events of the input, and outputs the remaining ones |
| Cca.uqac.lif.cep.tmf.Prefix | Returns the first n input events and discards the following ones |
| Cca.uqac.lif.cep.tmf.VariableStutter | Processor that repeats input events a number of times based on a control signal |
| Cca.uqac.lif.cep.tmf.WindowFunction | Takes a sliding window of n successive input events, passes them to an n-ary function and outputs the result |
| Cca.uqac.lif.cep.util.Bags.RunOn | Runs each element of a collection into a processor, and collect its output |
| Cca.uqac.lif.cep.util.FindPattern | Extracts chunks of an input stream based on a regular expression |
| Cca.uqac.lif.cep.util.Lists.AbstractPack | Common ancestor to TimePack and Pack |
| Cca.uqac.lif.cep.util.Lists.Pack | Accumulates events from a first input pipe, and sends them in a burst into a list based on the Boolean value received on its second input pipe |
| Cca.uqac.lif.cep.util.Lists.TimePack | Accumulates events that are being pushed, and sends them in a burst into a list at predefined time intervals |
| Cca.uqac.lif.cep.util.Lists.Unpack | Unpacks a collection of objects by outputting its contents as separate events |
| Cca.uqac.lif.cep.util.Multiset.PutInto | Puts incoming events into a multiset, and returns this set |
| Cca.uqac.lif.cep.functions.ApplyFunctionPartial | Evaluates a function on each event front in a lazy manner |
| Cca.uqac.lif.cep.tmf.Divert | Diverts an input stream to one of many downstream processor chains |
| Cca.uqac.lif.cep.tmf.Multiplex | Merges the contents of multiple traces into a single trace |
| Cca.uqac.lif.cep.tmf.Pump | Processor that repeatedly pulls its input, and pushes the resulting events to its output |
| Cca.uqac.lif.cep.tmf.Tank | Accumulates pushed events into a queue until they are pulled |
| Cca.uqac.lif.cep.tmf.TankLast | Tank that, when pulled, creates an output event based on the last event received |
| Cca.uqac.lif.cep.Duplicable | Interface indicating that an object can be duplicated |
| Cca.uqac.lif.cep.DuplicableProcessor | An override on the return type of Duplicable that enforces the return of a processor |
| Cca.uqac.lif.cep.Processor | Receives zero or more input events, and produces zero or more output events |
| Cca.uqac.lif.cep.functions.DuplicableFunction | Interface implemented by functions that can be duplicated |
| Cca.uqac.lif.cep.functions.Function | Represents a stateless m-to-n function |
| Cca.uqac.lif.cep.functions.ApplyFunctionArgument | A function of two arguments, the first of which is a 1:1 function; it applies this function to the second argument and returns the result |
| Cca.uqac.lif.cep.functions.BinaryFunction< T, V, U > | Function of two inputs and one output |
| Cca.uqac.lif.cep.util.Bags.Contains | Checks if an object is a member of a collection |
| Cca.uqac.lif.cep.util.Bags.IsElement | Checks if an element is a member of a collection |
| Cca.uqac.lif.cep.util.Bags.Product | Computes the Cartesian product of two collections, returning pairs as arrays |
| Cca.uqac.lif.cep.util.Booleans.And | Implementation of the logical conjunction |
| Cca.uqac.lif.cep.util.Booleans.Implies | Implementation of the logical implication |
| Cca.uqac.lif.cep.util.Booleans.Or | Implementation of the logical disjunction |
| Cca.uqac.lif.cep.util.Equals | A function that checks for the equality of various data types |
| Cca.uqac.lif.cep.util.Lists.Product | Computes the Cartesian product of two collections, returning pairs as MathLists |
| Cca.uqac.lif.cep.util.Multiset.Insert | Given a multiset and an element, returns a new multiset with this element added to it |
| Cca.uqac.lif.cep.util.Numbers.Addition | Computes the sum of its arguments |
| Cca.uqac.lif.cep.util.Numbers.Division | Computes the quotient of its arguments |
| Cca.uqac.lif.cep.util.Numbers.IsGreaterOrEqual | Checks if a number is greater than or equal to an other number |
| Cca.uqac.lif.cep.util.Numbers.IsGreaterThan | Checks if a number is greater than other number |
| Cca.uqac.lif.cep.util.Numbers.IsLessOrEqual | Checks if a number is less than or equal to an other number |
| Cca.uqac.lif.cep.util.Numbers.IsLessThan | Checks if a number is less than an other number |
| Cca.uqac.lif.cep.util.Numbers.Maximum | Returns the maximum of two numbers |
| Cca.uqac.lif.cep.util.Numbers.Minimum | Returns the minimum of two numbers |
| Cca.uqac.lif.cep.util.Numbers.Modulo | Evaluates the remainder of modulus division |
| Cca.uqac.lif.cep.util.Numbers.Multiplication | Computes the product of its arguments |
| Cca.uqac.lif.cep.util.Numbers.Power | Computes the power of its arguments |
| Cca.uqac.lif.cep.util.Numbers.Subtraction | Computes the difference of its arguments |
| Cca.uqac.lif.cep.util.Sets.IsSubsetOrEqual | Checks if a set is a subset of another |
| Cca.uqac.lif.cep.util.Sets.IsSupersetOrEqual | Checks if a set is a superset of another |
| Cca.uqac.lif.cep.util.Strings.Concat | Concatenates two strings |
| Cca.uqac.lif.cep.util.Strings.Contains | Function that checks if a string contains another |
| Cca.uqac.lif.cep.util.Strings.EndsWith | Function that checks if a string ends by another |
| Cca.uqac.lif.cep.util.Strings.Matches | Checks if a string matches a regular expression |
| Cca.uqac.lif.cep.util.Strings.StartsWith | Checks if a string starts by another |
| Cca.uqac.lif.cep.functions.Constant | Representation of a unary constant |
| Cca.uqac.lif.cep.functions.FunctionLambda | A function defined based on a lambda expression |
| Cca.uqac.lif.cep.functions.FunctionTree | A Function object representing the composition of multiple functions together to form a "compound" function |
| Cca.uqac.lif.cep.functions.IdentityFunction | Function that returns its input for its output |
| Cca.uqac.lif.cep.functions.IfThenElse | Function that acts as an if-then-else |
| Cca.uqac.lif.cep.functions.PassthroughFunction | Delegates all calls of the Function class to an internal object instantiated by a method |
| Cca.uqac.lif.cep.functions.RaiseArity | A Function that raises the arity of another function |
| Cca.uqac.lif.cep.functions.UnaryFunction< T, U > | Function of one input and one output |
| Cca.uqac.lif.cep.util.Bags.AnyElement | Returns any element of a collection |
| Cca.uqac.lif.cep.util.Bags.ApplyToAll | Given a set/list/array, returns a new set/list/array whose content is the result of applying a function to each element |
| Cca.uqac.lif.cep.util.Bags.FilterElements | Gets all the elements of the collection that satisfy some condition |
| Cca.uqac.lif.cep.util.Bags.GetSize | Gets the size of a collection |
| Cca.uqac.lif.cep.util.Bags.MaximumValue | Returns the element with the maximum value in a collection |
| Cca.uqac.lif.cep.util.Bags.MinimumValue | Returns the element with the maximum value in a collection |
| Cca.uqac.lif.cep.util.Booleans.BagAnd | Implementation of the logical conjunction over a collection |
| Cca.uqac.lif.cep.util.Booleans.BagOr | Implementation of the logical disjunction over a collection |
| Cca.uqac.lif.cep.util.Booleans.BooleanCast | Function that attempts to convert an object into a Boolean |
| Cca.uqac.lif.cep.util.Booleans.Not | Implementation of the logical negation |
| Cca.uqac.lif.cep.util.InstanceOf | Checks if an object is an instance of a given class |
| Cca.uqac.lif.cep.util.Lists.Sort< T extends Comparable< T > > | |
| Cca.uqac.lif.cep.util.Lists.SortOn< T > | |
| Cca.uqac.lif.cep.util.Maps.ApplyAll | Creates a new map by applying a function to all the values of a map given as input |
| Cca.uqac.lif.cep.util.Maps.FilterMap | Filters a map based on a condition on its key-value pairs |
| Cca.uqac.lif.cep.util.Maps.Get | Gets a value in the map, based on the name of a key |
| Cca.uqac.lif.cep.util.Maps.Keys | Gets the set of keys in a map |
| Cca.uqac.lif.cep.util.Maps.MultiValues | Gets the multi-set of values in a map |
| Cca.uqac.lif.cep.util.Maps.Values | Gets the set of values in a map |
| Cca.uqac.lif.cep.util.Multiset.GetCardinalities | Gets the cardinalities of each element in a multiset |
| Cca.uqac.lif.cep.util.NthElement | Function that returns the n-th element of an ordered collection (array or list) |
| Cca.uqac.lif.cep.util.Numbers.AbsoluteValue | Computes the absolute value of its argument |
| Cca.uqac.lif.cep.util.Numbers.Ceiling | Rounds a number up to the nearest integer |
| Cca.uqac.lif.cep.util.Numbers.Floor | Rounds a number down to the nearest integer |
| Cca.uqac.lif.cep.util.Numbers.IsEven | Computes if a number is even |
| Cca.uqac.lif.cep.util.Numbers.NumberCast | Converts an object into a number |
| Cca.uqac.lif.cep.util.Numbers.Signum | Computes the signum of its argument |
| Cca.uqac.lif.cep.util.Numbers.Square | Computes the square of a number |
| Cca.uqac.lif.cep.util.Numbers.SquareRoot | Computes the square root of its argument |
| Cca.uqac.lif.cep.util.Size | Evaluates the size of an object |
| Cca.uqac.lif.cep.util.Strings.FindRegex | Finds all substrings that match capturing group 1 of a regular expression |
| Cca.uqac.lif.cep.util.Strings.FindRegexOnce | Finds the first substring that matches capturing group 1 of a regular expression |
| Cca.uqac.lif.cep.util.Strings.ReplaceAll | Replaces all matches of a regular expression by another regular expression |
| Cca.uqac.lif.cep.util.Strings.SplitString | Transforms a comma-separated line of text into an array |
| Cca.uqac.lif.cep.util.Strings.Substring | Extracts a sub-string out of another string |
| Cca.uqac.lif.cep.util.Strings.ToString | Transforms any object into a string using the "toString" method |
| Cca.uqac.lif.cep.functions.Variable | A function that acts as a placeholder for a value to be computed at a later time |
| Cca.uqac.lif.cep.functions.ContextVariable | Placeholder for the value of a context element |
| Cca.uqac.lif.cep.functions.StreamVariable | Symbol standing for the i-th trace given as input |
| Cca.uqac.lif.cep.util.Bags.Explode | A 1:m function provided by the Bags utility class |
| Cca.uqac.lif.cep.util.Bags.ToCollection | Converts a front of n input events into a collection of n objects |
| Cca.uqac.lif.cep.util.Bags.ToArray | Converts a front of n events into an array of n objects |
| Cca.uqac.lif.cep.util.Bags.ToList | Converts a front of n events into a list of n objects |
| Cca.uqac.lif.cep.util.Bags.ToSet | Converts a front of n events into a set of n objects |
| Cca.uqac.lif.cep.tmf.PushUnit | The encapsulation of a 1:1 processor connected to a sink |
| Cca.uqac.lif.cep.EventNodeFunction | |
| Cca.uqac.lif.cep.EventTracker | Tracks the relationship between output events produced by processors, and the input events that were used to compute them |
| Cca.uqac.lif.cep.EventTracker.NoOpEventTracker | Dummy event tracker that does nothing |
| Cca.uqac.lif.cep.functions.ApplyFunction.ShiftTracker | Simple tracker proxy that records associations from the underlying function, and shifts its input/output by the current position in the input/output stream |
| CHashMap | |
| Cca.uqac.lif.cep.Context | Associative map used by processors to store persistent data |
| Cca.uqac.lif.cep.util.Maps.MathMap< K, V > | A map that implements equality based on its contents |
| CHashSet | |
| Cca.uqac.lif.cep.util.Sets.MathSet< T > | Implementation of a set with "mathematical" equality |
| Cca.uqac.lif.cep.GroupProcessor.InputOutputAssociation | |
| Cca.uqac.lif.cep.Processor.InternalProcessorState | An object capturing the internal state of a processor, including the current contents of its input and output queues |
| CIterable | |
| Cca.uqac.lif.cep.Pullable | Queries events on one of a processor's outputs |
| Cca.uqac.lif.cep.AsynchronousProcessor.OutputPullable | |
| Cca.uqac.lif.cep.GroupProcessor.ProxyPullable | |
| Cca.uqac.lif.cep.Pullable.PullNotSupported | Pullable object that throws an UnsupportedOperationException upon every call to each of its methods (except getProcessor()) |
| Cca.uqac.lif.cep.SynchronousProcessor.OutputPullable | Implementation of a Pullable for a single processor |
| Cca.uqac.lif.cep.tmf.Insert.InsertPullable | A Pullable object that does not pull events from upstream before the events to insert have been emitted |
| Cca.uqac.lif.cep.TypedPullable< T > | A Pullable object that casts all its output to a given type |
| Cca.uqac.lif.cep.UniformProcessor.UnaryPullable | A special type of Pushable for uniform processors with an input and output arity of exactly 1 |
| Cca.uqac.lif.cep.functions.ApplyFunctionPartial.OutputPullable | |
| Cca.uqac.lif.cep.tmf.Divert.DivertPullable | Implementation of the Pullable interface for the Divert processor |
| Cca.uqac.lif.cep.tmf.Multiplex.MuxPullable | |
| Cca.uqac.lif.cep.tmf.Tank.QueuePullable | |
| CIterator | |
| Cca.uqac.lif.cep.Pullable | Queries events on one of a processor's outputs |
| Cca.uqac.lif.cep.functions.ApplyFunctionLambda.LambdaEvaluable | |
| Cca.uqac.lif.cep.util.Lists | A container object for functions and processors applying to lists |
| Cca.uqac.lif.cep.Main | A dummy main file defining a few system-wide constants |
| Cca.uqac.lif.cep.util.Maps | A container object for map functions and processors |
| Cca.uqac.lif.cep.Pullable.NextStatus | The "next" status of a Pullable object |
| CNodeFunction | |
| Cca.uqac.lif.cep.functions.Cumulate.StartValue | Node function representing the start value defined for a particular function |
| Cca.uqac.lif.cep.tmf.QueueSource.QueueFunction | Provenance function that links an output event to an element of the processor's queue |
| Cca.uqac.lif.cep.util.Numbers | A container object for functions applying to numbers |
| COutputPullable | |
| Cca.uqac.lif.cep.io.ReadInputStream.ReadInputStreamPullable | A special Pullable that overrides the default behavior of SynchronousProcessor.OutputPullable |
| Cca.uqac.lif.cep.PipeCrawler | An object that visits every processor in a chain, from a processor used as a starting point |
| Cca.uqac.lif.cep.GroupProcessor.CollectCrawler | A crawler that adds to the group any processor it encounters |
| Cca.uqac.lif.cep.GroupProcessor.CopyCrawler | Crawler that creates copies (clones) of whatever it encounters on its way and re-pipes processors as in the original group |
| Cca.uqac.lif.cep.Connector.PipeSelector | An object that holds a reference to a processor, and which can produce a SelectedPipe for a given index |
| CPrintable | |
| Cca.uqac.lif.cep.Processor | Receives zero or more input events, and produces zero or more output events |
| Cca.uqac.lif.cep.functions.ContextAssignment | An object that assigns a value to a specific key in a Context object |
| Cca.uqac.lif.cep.functions.Function | Represents a stateless m-to-n function |
| Cca.uqac.lif.cep.GroupProcessor.ProcessorAssociation | Tuple made of a number and a processor |
| Cca.uqac.lif.cep.Pushable | Gives events to some of a processor's input |
| Cca.uqac.lif.cep.AsynchronousProcessor.InputPushable | |
| Cca.uqac.lif.cep.GroupProcessor.ProxyPushable | |
| Cca.uqac.lif.cep.Pushable.PushNotSupported | Pushable object that throws an UnsupportedOperationException upon every call to each of its methods (except getProcessor()) |
| Cca.uqac.lif.cep.SynchronousProcessor.InputPushable | Implementation of a Pushable for a single processor |
| Cca.uqac.lif.cep.UniformProcessor.UnaryPushable | A special type of Pushable for uniform processors with an input and output arity of exactly 1 |
| Cca.uqac.lif.cep.functions.ApplyFunctionPartial.InputPushable | |
| Cca.uqac.lif.cep.tmf.Divert.DivertPushable | Implementation of the Pushable interface for the Divert processor |
| Cca.uqac.lif.cep.tmf.Multiplex.MuxPushable | |
| Cca.uqac.lif.cep.tmf.Tank.QueuePushable | |
| CReadable | |
| Cca.uqac.lif.cep.Processor | Receives zero or more input events, and produces zero or more output events |
| Cca.uqac.lif.cep.functions.ContextAssignment | An object that assigns a value to a specific key in a Context object |
| Cca.uqac.lif.cep.functions.Function | Represents a stateless m-to-n function |
| CRunnable | |
| Cca.uqac.lif.cep.tmf.Pump | Processor that repeatedly pulls its input, and pushes the resulting events to its output |
| Cca.uqac.lif.cep.util.Lists.TimePack.Timer | Timer that pushes the contents of m_packedEvents every m_outputInterval milliseconds |
| CRuntimeException | |
| Cca.uqac.lif.cep.Connector.ConnectorException | Exception thrown when a problem occurs when attempting to connect two objects |
| Cca.uqac.lif.cep.Connector.ConnectionException | Exception thrown when a problem occurs when connecting the output pipe of a processor to the input pipe of another one |
| Cca.uqac.lif.cep.Connector.IncompatibleTypesException | Exception thrown when two processors with incompatible input/output types are attempted to be connected |
| Cca.uqac.lif.cep.Connector.IndexOutOfBoundsException | Exception thrown when the connector is asked to pipe something to a nonexistent input or output |
| Cca.uqac.lif.cep.Connector.SelfLoopException | Exception thrown when trying to connect the output of a processor to its own input |
| Cca.uqac.lif.cep.ProcessorException | Generic class for any exception thrown in the lifecycle of a processor |
| Cca.uqac.lif.cep.Pullable.PullableException | A runtime exception indicating that something went wrong when attempting to check if a next event exists |
| Cca.uqac.lif.cep.Pushable.PushableException | A runtime exception indicating that something went wrong when attempting to check if a next event exists |
| Cca.uqac.lif.cep.functions.FunctionException | Generic class for any exception thrown during the evaluation of a function |
| Cca.uqac.lif.cep.functions.InvalidArgumentException | Exception thrown when a function is given an argument that is invalid |
| Cca.uqac.lif.cep.functions.NothingToReturnException | Exception thrown when a function cannot produce a return value |
| Cca.uqac.lif.cep.Connector.SelectedPipe | An object that designates a specific input or output pipe for a specific processor |
| Cca.uqac.lif.cep.Connector.SelectedInputPipe | |
| Cca.uqac.lif.cep.Connector.SelectedOutputPipe | |
| CSet | |
| Cca.uqac.lif.cep.util.Multiset | A set where each element can be present more than once |
| Cca.uqac.lif.cep.util.Sets | A container object for set functions and processors |
| Cca.uqac.lif.cep.Stateful | Interface implemented by processors that can publicly expose a token equivalent to their internal state |
| Cca.uqac.lif.cep.GroupProcessor | Encapsulates a chain of processors as if it were a single one |
| Cca.uqac.lif.cep.functions.ApplyFunction | Applies a function to input events to produce output events |
| Cca.uqac.lif.cep.functions.Cumulate | Creates a cumulative processor out of a cumulative function |
| Cca.uqac.lif.cep.functions.TurnInto | Processor that turns any event into a predefined object |
| Cca.uqac.lif.cep.tmf.AbstractSlice | Separates an input trace into different "slices" |
| Cca.uqac.lif.cep.tmf.CountDecimate | Returns one input event and discards the next n-1 |
| Cca.uqac.lif.cep.tmf.Filter | Discards events from an input trace based on a selection criterion |
| Cca.uqac.lif.cep.tmf.Freeze | Repeatedly outputs the first event it has received |
| Cca.uqac.lif.cep.tmf.Insert | Inserts an event a certain number of times before letting the input events through |
| Cca.uqac.lif.cep.tmf.Passthrough | Returns its input as its output |
| Cca.uqac.lif.cep.tmf.Pump | Processor that repeatedly pulls its input, and pushes the resulting events to its output |
| Cca.uqac.lif.cep.tmf.QueueSource | Source whose input is a queue of objects |
| Cca.uqac.lif.cep.tmf.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 |
| Cca.uqac.lif.cep.tmf.Stutter | Repeats each input event a specified number of times |
| Cca.uqac.lif.cep.tmf.Trim | Discards the first n events of the input, and outputs the remaining ones |
| Cca.uqac.lif.cep.tmf.Window | Simulates the application of a "sliding window" to a trace |
| Cca.uqac.lif.cep.util.Sets.SetUpdateProcessor | Processor that updates a set |
| Cca.uqac.lif.cep.util.Strings | A container object for string functions |
| CThread | |
| Cca.uqac.lif.cep.io.CommandRunner | Utility class to run commands on the command line and fetch their output |
| Cca.uqac.lif.cep.io.CommandRunner.StreamGobbler | Constantly reads an input stream and captures its content |
| Cca.uqac.lif.cep.tmf.AbstractSlice.ToAllSlices | Dummy object telling the slicer that an event must be sent to all slices |
| Cca.uqac.lif.cep.functions.UnaryFunction< T, T > | |
| Cca.uqac.lif.cep.functions.CumulativeFunction< T > | A function with memory |
| Cca.uqac.lif.cep.functions.ApplyFunctionLambda.UnaryLambdaEvaluable | |
| Cca.uqac.lif.cep.functions.FunctionLambda.UnaryLambdaEvaluable | |
| Cca.uqac.lif.cep.UtilityMethods | A few methods repeatedly used throughout the code repository examples |
| Cca.uqac.lif.cep.Connector.Variant | Empty class representing the fact that the output type of a processor may vary |
1.15.0