| Cca.uqac.lif.cep.util.Bags | A container object for functions and processors applying to generic collections, i.e |
| Cca.uqac.lif.cep.functions.BinaryFunction< Boolean, Boolean, Boolean > | |
| Cca.uqac.lif.cep.functions.BinaryFunction< Collection, Collection, Collection > | |
| Cca.uqac.lif.cep.functions.BinaryFunction< Collection, Object, Boolean > | |
| Cca.uqac.lif.cep.functions.BinaryFunction< Multiset, Object, Multiset > | |
| Cca.uqac.lif.cep.functions.BinaryFunction< Number, Number, Boolean > | |
| Cca.uqac.lif.cep.functions.BinaryFunction< Number, Number, Number > | |
| Cca.uqac.lif.cep.functions.BinaryFunction< Object, Collection, Boolean > | |
| Cca.uqac.lif.cep.functions.BinaryFunction< Object, Object, Boolean > | |
| Cca.uqac.lif.cep.functions.BinaryFunction< Object, Object, String > | |
| Cca.uqac.lif.cep.functions.BinaryFunction< Set, Set, Boolean > | |
| Cca.uqac.lif.cep.functions.BinaryFunction< String, String, Boolean > | |
| Cca.uqac.lif.cep.functions.BinaryFunction< T, T, T > | |
| Cca.uqac.lif.cep.functions.FunctionLambda.BinaryLambdaEvaluable | |
| Cca.uqac.lif.cep.functions.ApplyFunctionLambda.BinaryLambdaEvaluable | |
| Cca.uqac.lif.cep.util.Booleans | A container object for Boolean functions |
| ►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.functions.ApplyFunctionPartial | Evaluates a function on each event front in a lazy manner |
| 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.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 even |
| ►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.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.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 |
| Cca.uqac.lif.cep.io.ReadLines | Source that reads text lines from a Java InputStream |
| Cca.uqac.lif.cep.io.ReadStringStream | Extracts character strings from a Java InputStream |
| ►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.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.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.PutInto | Updates a set |
| Cca.uqac.lif.cep.util.Sets.PutIntoNew | Updates a set |
| Cca.uqac.lif.cep.util.Strings.BuildString | Concatenates input strings into an output string |
| 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.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 |
| 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.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.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.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.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.Get | Gets a value in the map, based on the name of a key |
| 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.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.SplitString | Transforms a comma-separated line of text into an array |
| 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.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 |
| Cca.uqac.lif.cep.FutureDone< ca.uqac.lif.cep.Pushable > | |
| 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.functions.ApplyFunctionPartial.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.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 | |
| 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.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.util.Maps.MathMap< Integer, ca.uqac.lif.cep.util.Lists.MathList< Object > > | |
| Cca.uqac.lif.cep.Pullable.NextStatus | The "next" status of a Pullable object |
| Cca.uqac.lif.cep.util.Numbers | A container object for functions applying to numbers |
| ►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.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.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.functions.ApplyFunctionPartial.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.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 | |
| Cca.uqac.lif.cep.UniformProcessor.UnaryPushable | A special type of Pushable for uniform processors with an input and output arity of exactly 1 |
| ►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.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.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.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.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.GroupProcessor | Encapsulates a chain of processors as if it were a single one |
| 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< Boolean, Boolean > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Collection, Number > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Collection, Object > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Map, Collection > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Map, Map > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Map, Object > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Multiset, Map > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Number, Boolean > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Number, Number > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Object, Boolean > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Object, Integer > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Object, Number > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Object, Object > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< Object, String > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< String, Object > | |
| Cca.uqac.lif.cep.functions.UnaryFunction< String, Set > | |
| ►Cca.uqac.lif.cep.functions.UnaryFunction< T, T > | |
| Cca.uqac.lif.cep.functions.CumulativeFunction< T > | A function with memory |
| Cca.uqac.lif.cep.functions.FunctionLambda.UnaryLambdaEvaluable | |
| Cca.uqac.lif.cep.functions.ApplyFunctionLambda.UnaryLambdaEvaluable | |
| Cca.uqac.lif.cep.UtilityMethods | A few methods repeatedly used throughout the code repository examples |
| ►CArrayList | |
| Cca.uqac.lif.cep.util.Lists.MathList< T > | A list that implements equality |
| ►CFuture | |
| Cca.uqac.lif.cep.CompoundFuture< T, U > | A Future object whose termination and output value depends on the termination and output values of multiple other Future objects |
| Cca.uqac.lif.cep.FutureDone< T > | A Future object indicating that the computation is completed |
| ►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 > | |
| ►CIterator | |
| Cca.uqac.lif.cep.Pullable | Queries events on one of a processor's outputs |
| ►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 |
| ►CPrintable | |
| 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.Processor | Receives zero or more input events, and produces zero or more output events |
| ►CReadable | |
| 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.Processor | Receives zero or more input events, and produces zero or more output events |
| ►CSet | |
| Cca.uqac.lif.cep.util.Multiset | A set where each element can be present more than once |
1.8.13