A B C D E F G H I J K L M N O P Q R S T U V W X
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- acceptsURL(String) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepDriver
- actionPerformed(ActionEvent) - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- add(int, Tuple) - Method in class ca.uqac.lif.cep.tuples.AttributeGroup
-
Add a tuple in a specific position in the group
- add(Predicate...) - Method in class ca.uqac.lif.cep.fol.InterpretationBuilder
- add(GroupProcessor) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
- add(Processor...) - Method in class ca.uqac.lif.cep.dsl.GroupProcessorBuilder
- addBatch() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- addDefinition(Predicate.PredicateArgument, boolean) - Method in class ca.uqac.lif.cep.fol.Predicate
-
Adds a new tuple to the definition of this predicate
- addInitialAssignment(ContextAssignment) - Method in class ca.uqac.lif.cep.fsm.MooreMachine
- addPredicate(Predicate) - Method in class ca.uqac.lif.cep.fol.Interpretation
-
Adds a new predicate to this interpretation
- addPredicateTuple(PredicateTuple) - Method in class ca.uqac.lif.cep.fol.Interpretation
-
Adds a new predicate tuple to the definition of some predicate.
- addSymbol(int, Function) - Method in class ca.uqac.lif.cep.fsm.MooreMachine
-
Associates an output symbol (i.e.
- addSymbols(int, Function...) - Method in class ca.uqac.lif.cep.fsm.MooreMachine
-
Associates output symbols (i.e.
- addToDomain(String, Object) - Method in class ca.uqac.lif.cep.fol.Interpretation
-
Adds a new value to a domain
- addTransition(int, MooreMachine.Transition) - Method in class ca.uqac.lif.cep.fsm.MooreMachine
-
Adds a transition to the machine
- AFTER - ca.uqac.lif.cep.complex.RangeCep.State
-
The event received is after the end of the range.
- allowRestarts(boolean) - Method in class ca.uqac.lif.cep.complex.RangeCep
-
Sets whether the processor is allowed to produce multiple successive complex events.
- And(Function, Function) - Constructor for class ca.uqac.lif.cep.fol.LazyBooleanFunction.And
- ApacheLogFeeder - Class in ca.uqac.lif.cep.apache
-
Converts a stream of lines from an Apache log into a stream of HTTP request objects
- ApacheLogFeeder() - Constructor for class ca.uqac.lif.cep.apache.ApacheLogFeeder
- AppendToTuple - Class in ca.uqac.lif.cep.tuples
- AppendToTuple(String[], Object[]) - Constructor for class ca.uqac.lif.cep.tuples.AppendToTuple
- AppendToTuple(String, Object) - Constructor for class ca.uqac.lif.cep.tuples.AppendToTuple
- ArrayAverage(int) - Constructor for class ca.uqac.lif.cep.signal.Smooth.ArrayAverage
- assignToContext(ContextAssignment) - Method in class ca.uqac.lif.cep.fsm.MooreMachine
- associateTo(int, NodeFunction, int, int) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
- associateToInput(int, int, int, int, int) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
- associateToOutput(int, int, int, int, int) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
- AttributeExpression - Class in ca.uqac.lif.cep.tuples
-
Association between an expression to compute a value from an AttributeGroup and an attribute name.
- AttributeExpression() - Constructor for class ca.uqac.lif.cep.tuples.AttributeExpression
- AttributeExpression(Function, String) - Constructor for class ca.uqac.lif.cep.tuples.AttributeExpression
-
Creates a new attribute expression
- AttributeGroup - Class in ca.uqac.lif.cep.tuples
-
A group of attributes taken from the merging of one or more tuples.
- AttributeGroup(String[]) - Constructor for class ca.uqac.lif.cep.tuples.AttributeGroup
-
Create a new attribute group, by specifying the names given to each tuple.
B
- BeepBeepConnection - Class in ca.uqac.lif.cep.jdbc
- BeepBeepDriver - Class in ca.uqac.lif.cep.jdbc
- BeepBeepDriver() - Constructor for class ca.uqac.lif.cep.jdbc.BeepBeepDriver
- BeepBeepPreparedStatement - Class in ca.uqac.lif.cep.jdbc
- BeepBeepResultSet - Class in ca.uqac.lif.cep.jdbc
- BeepBeepStatement - Class in ca.uqac.lif.cep.jdbc
- BEFORE - ca.uqac.lif.cep.complex.RangeCep.State
-
The event received lies before the start of the range.
- Blow - Class in ca.uqac.lif.cep.tuples
-
Breaks a single tuple into multiple tuples, one for each key-value pair of the original tuple.
- Blow() - Constructor for class ca.uqac.lif.cep.tuples.Blow
- build(InputStream) - Method in class ca.uqac.lif.cep.dsl.MultilineGroupProcessorBuilder
- build(String) - Method in class ca.uqac.lif.cep.dsl.GrammarObjectBuilder
-
Builds an object from an expression
- build(String) - Method in class ca.uqac.lif.cep.dsl.MultilineGroupProcessorBuilder
- build(ArrayDeque<Object>) - Static method in class ca.uqac.lif.cep.signal.Limit
- build(ArrayDeque<Object>) - Static method in class ca.uqac.lif.cep.tuples.AttributeExpression
- build(ArrayDeque<Object>) - Static method in class ca.uqac.lif.cep.tuples.FetchAttribute
- build(ArrayDeque<Object>) - Static method in class ca.uqac.lif.cep.tuples.From
- build(ArrayDeque<Object>) - Static method in class ca.uqac.lif.cep.tuples.GetAttribute
- build(ArrayDeque<Object>) - Static method in class ca.uqac.lif.cep.tuples.RegexTupleBuilder
- build(ArrayDeque<Object>) - Static method in class ca.uqac.lif.cep.tuples.RegexTupleBuilder.RegexAttributeNameList
- build(ArrayDeque<Object>) - Static method in class ca.uqac.lif.cep.tuples.Select
- build(ArrayDeque<Object>) - Static method in class ca.uqac.lif.cep.tuples.Where
- build(Scanner) - Method in class ca.uqac.lif.cep.dsl.MultilineGroupProcessorBuilder
- buildLine(String) - Method in class ca.uqac.lif.cep.dsl.MultilineGroupProcessorBuilder
C
- ca.uqac.lif.cep.apache - package ca.uqac.lif.cep.apache
-
A palette for processing Apache log files
- ca.uqac.lif.cep.complex - package ca.uqac.lif.cep.complex
-
A set of processors to perform Complex Event Processing.
- ca.uqac.lif.cep.diagnostics - package ca.uqac.lif.cep.diagnostics
-
A set of processors and functions used to debug and diagnose problems in a processor chain.
- ca.uqac.lif.cep.dsl - package ca.uqac.lif.cep.dsl
-
Create domain-specific languages (DSL) by interacting with the Bullwinkle parser.
- ca.uqac.lif.cep.fol - package ca.uqac.lif.cep.fol
-
Processors for creating a first-order interpretation from a trace of predicates.
- ca.uqac.lif.cep.fsm - package ca.uqac.lif.cep.fsm
-
Define and run extended finite-state machines (FSMs) on an input trace.
- ca.uqac.lif.cep.hibernate - package ca.uqac.lif.cep.hibernate
-
Palette that provides functionalities for serializing processors.
- ca.uqac.lif.cep.http - package ca.uqac.lif.cep.http
-
Use HTTP mini-servers as event sources or sinks.
- ca.uqac.lif.cep.io.websocket - package ca.uqac.lif.cep.io.websocket
-
Processors to read and write events from/to a web socket.
- ca.uqac.lif.cep.jdbc - package ca.uqac.lif.cep.jdbc
-
A set of wrapper classes to make BeepBeep work like a JDBC driver on a relational database.
- ca.uqac.lif.cep.json - package ca.uqac.lif.cep.json
-
Processors to perform JSON parsing and evaluate simple path expressions.
- ca.uqac.lif.cep.mtnp - package ca.uqac.lif.cep.mtnp
-
Manipulate tables and plots, using GRAL or Gnuplot as a back-end.
- ca.uqac.lif.cep.provenance - package ca.uqac.lif.cep.provenance
-
Track lineage information between inputs and outputs of a processor chain.
- ca.uqac.lif.cep.serialization - package ca.uqac.lif.cep.serialization
-
Serialize and deserialize events using the Azrael serialization library.
- ca.uqac.lif.cep.signal - package ca.uqac.lif.cep.signal
-
Signal processing functionalities: peak detection, threshold, etc.
- ca.uqac.lif.cep.tuples - package ca.uqac.lif.cep.tuples
-
Manipulate tuples using SQL-like operations such as
SELECT
,FROM
andWHERE
. - ca.uqac.lif.cep.widgets - package ca.uqac.lif.cep.widgets
-
Use AWT and Swing widgets and event sources or sinks.
- ca.uqac.lif.cep.xml - package ca.uqac.lif.cep.xml
-
Processors to perform XML parsing and evaluate simple XPath expressions.
- CacheMap<T> - Class in ca.uqac.lif.cep.tuples
-
Implementation of an immutable map.
- CacheMap(String[]) - Constructor for class ca.uqac.lif.cep.tuples.CacheMap
- CacheMap(String[], Object[]) - Constructor for class ca.uqac.lif.cep.tuples.CacheMap
- castValue(XmlElement) - Method in class ca.uqac.lif.cep.xml.XPathFunctionGet
- castValue(XmlElement) - Method in class ca.uqac.lif.cep.xml.XPathFunctionGetNumber
- castValue(XmlElement) - Method in class ca.uqac.lif.cep.xml.XPathFunctionGetText
- changeComponent(Component, Object[]) - Method in class ca.uqac.lif.cep.widgets.WidgetSink
- clear() - Method in class ca.uqac.lif.cep.fol.Interpretation
-
Clears this interpretation of all predicate and domain definitions
- clear() - Method in class ca.uqac.lif.cep.fol.Predicate
- clear() - Method in class ca.uqac.lif.cep.tuples.CacheMap
- clear() - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- clear() - Method in class ca.uqac.lif.cep.tuples.TupleMap
- clearParameters() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- close() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepConnection
- CommandRunner - Class in ca.uqac.lif.cep.provenance
-
Facilitates the execution of an external command and the collection of its output
- CommandRunner(String[]) - Constructor for class ca.uqac.lif.cep.provenance.CommandRunner
-
Creates a CommandRunner to run a command.
- CommandRunner(String[], String) - Constructor for class ca.uqac.lif.cep.provenance.CommandRunner
-
Creates a CommandRunner to run a command.
- CommandRunner(List<String>, String) - Constructor for class ca.uqac.lif.cep.provenance.CommandRunner
-
Creates a CommandRunner to run a command.
- CommandRunner.StreamGobbler - Class in ca.uqac.lif.cep.provenance
-
Constantly reads an input stream and captures its content.
- compare(Tuple, Tuple) - Method in class ca.uqac.lif.cep.tuples.TupleComparator
- compute(Object[], Object[]) - Method in class ca.uqac.lif.cep.diagnostics.PassthroughCounter
- compute(Object[], Object[]) - Method in class ca.uqac.lif.cep.diagnostics.PrintThrough
- compute(Object[], Object[]) - Method in class ca.uqac.lif.cep.mtnp.DrawPlot
- compute(Object[], Object[]) - Method in class ca.uqac.lif.cep.mtnp.PrintGnuPlot
- compute(Object[], Object[]) - Method in class ca.uqac.lif.cep.mtnp.UpdateTableArray
- compute(Object[], Object[]) - Method in class ca.uqac.lif.cep.mtnp.UpdateTableMap
- compute(Object[], Object[]) - Method in class ca.uqac.lif.cep.mtnp.UpdateTableStream
- compute(Object[], Object[]) - Method in class ca.uqac.lif.cep.signal.Noise
- compute(Object[], Object[]) - Method in class ca.uqac.lif.cep.signal.Persist
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.complex.RangeCep
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.diagnostics.Derivation
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.diagnostics.ThroughputMeter
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.fol.InterpretationBuilder
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.fsm.MooreMachine
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.hibernate.Hibernate
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.http.HttpDownstreamGateway
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.http.HttpSource
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.http.HttpUpstreamGateway
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.io.websocket.WebSocketReader
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.jdbc.JdbcSource
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.json.JsonLineFeeder
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.signal.Limit
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.signal.PeakFinderLocalMaximum
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.signal.PeakFinderTravelRise
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.signal.PlateauFinder
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.signal.Threshold
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.tuples.RegexTupleBuilder
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.tuples.TupleFeeder
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.tuples.Where
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- compute(Object[], Queue<Object[]>) - Method in class ca.uqac.lif.cep.widgets.WidgetSink
- computeOutputValue() - Method in class ca.uqac.lif.cep.signal.PeakFinderLocalMaximum
- computeOutputValue() - Method in class ca.uqac.lif.cep.signal.PeakFinderTravelRise
- computeOutputValue() - Method in class ca.uqac.lif.cep.signal.PlateauFinder
- computeOutputValue() - Method in class ca.uqac.lif.cep.signal.WindowProcessor
- connect(String, Properties) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepDriver
- containsKey(Object) - Method in class ca.uqac.lif.cep.tuples.CacheMap
- containsKey(Object) - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- containsKey(Object) - Method in class ca.uqac.lif.cep.tuples.TupleMap
- containsPredicate(String) - Method in class ca.uqac.lif.cep.fol.Interpretation
-
Checks if this interpretation contains a predicate with given name
- containsValue(Object) - Method in class ca.uqac.lif.cep.tuples.CacheMap
- containsValue(Object) - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- containsValue(Object) - Method in class ca.uqac.lif.cep.tuples.TupleMap
- createConnection(Interpreter, String, Properties) - Static method in class ca.uqac.lif.cep.jdbc.BeepBeepDriver
-
Creates a new database connection to a given URL.
- createEntry(Object[]) - Method in class ca.uqac.lif.cep.mtnp.UpdateTable
-
Creates a table entry from an array of objects
- createStatement() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepConnection
- createTuple(Object...) - Method in class ca.uqac.lif.cep.tuples.FixedTupleBuilder
- createTupleFromString(String[]) - Method in class ca.uqac.lif.cep.tuples.FixedTupleBuilder
D
- dateToTimestamp(Calendar, String) - Static method in class ca.uqac.lif.cep.apache.HttpRequest
-
Converts a date in the format YYYY-MM-DD HH:MM:SS into a Unix timestamp.
- DELETE - ca.uqac.lif.cep.apache.HttpRequest.Method
- dependsOn() - Method in class ca.uqac.lif.cep.provenance.EventFunction
- Derivation - Class in ca.uqac.lif.cep.diagnostics
- Derivation(long, Processor...) - Constructor for class ca.uqac.lif.cep.diagnostics.Derivation
-
Creates a new derivation
- Derivation(Processor...) - Constructor for class ca.uqac.lif.cep.diagnostics.Derivation
-
Creates a new derivation
- DeserializeEvents<T,U> - Class in ca.uqac.lif.cep.serialization
-
Function that applies a deserializer to its input argument.
- DeserializeEvents(ObjectReader<T>, Class<T>, Class<U>) - Constructor for class ca.uqac.lif.cep.serialization.DeserializeEvents
-
Creates a new instance of the function.
- DiagnosticsCallback - Class in ca.uqac.lif.cep.diagnostics
-
Empty class representing a callback for a diagnostics function
- DiagnosticsCallback() - Constructor for class ca.uqac.lif.cep.diagnostics.DiagnosticsCallback
- DotProvenanceTreeRenderer - Class in ca.uqac.lif.cep.provenance
-
Renders a provenance node into a picture
- DotProvenanceTreeRenderer() - Constructor for class ca.uqac.lif.cep.provenance.DotProvenanceTreeRenderer
- doubleEquals(double, double) - Static method in class ca.uqac.lif.cep.signal.WindowProcessor
- DrawPlot - Class in ca.uqac.lif.cep.mtnp
-
Generates a bitmap from a
Table
object. - DrawPlot() - Constructor for class ca.uqac.lif.cep.mtnp.DrawPlot
- DrawPlot(Plot) - Constructor for class ca.uqac.lif.cep.mtnp.DrawPlot
- DrawPlot(Plot, Plot.ImageType) - Constructor for class ca.uqac.lif.cep.mtnp.DrawPlot
- duplicate() - Method in class ca.uqac.lif.cep.fsm.MooreMachine.Transition
- duplicate() - Method in class ca.uqac.lif.cep.tuples.Tuple
- duplicate(boolean) - Method in class ca.uqac.lif.cep.apache.ApacheLogFeeder
- duplicate(boolean) - Method in class ca.uqac.lif.cep.complex.RangeCep
- duplicate(boolean) - Method in class ca.uqac.lif.cep.diagnostics.Derivation
- duplicate(boolean) - Method in class ca.uqac.lif.cep.diagnostics.PassthroughCounter
- duplicate(boolean) - Method in class ca.uqac.lif.cep.diagnostics.ThroughputMeter
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.Exists
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.ExistsInterpretation
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.ForAll
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.ForAllInterpretation
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.GetDomain
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.InterpretationBuilder
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction.And
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction.DummyInterpretationFunction
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction.Implies
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction.Or
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.Predicate
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.Predicate.Wildcard
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.PredicateAssertion
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.PredicateGet
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.PredicateGetNumber
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.PredicateTupleConversion
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fol.PredicateTupleReader
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fsm.FunctionTransition
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fsm.MooreMachine
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fsm.MooreMachine.Transition
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fsm.ProcessorTransition
- duplicate(boolean) - Method in class ca.uqac.lif.cep.fsm.TransitionOtherwise
- duplicate(boolean) - Method in class ca.uqac.lif.cep.hibernate.Hibernate
- duplicate(boolean) - Method in class ca.uqac.lif.cep.http.HttpDownstreamGateway
- duplicate(boolean) - Method in class ca.uqac.lif.cep.http.HttpSource
- duplicate(boolean) - Method in class ca.uqac.lif.cep.http.HttpUpstreamGateway
- duplicate(boolean) - Method in class ca.uqac.lif.cep.io.websocket.WebSocketReader
- duplicate(boolean) - Method in class ca.uqac.lif.cep.jdbc.JdbcSource
- duplicate(boolean) - Method in class ca.uqac.lif.cep.json.JsonLineFeeder
- duplicate(boolean) - Method in class ca.uqac.lif.cep.mtnp.DrawPlot
- duplicate(boolean) - Method in class ca.uqac.lif.cep.mtnp.PrintGnuPlot
- duplicate(boolean) - Method in class ca.uqac.lif.cep.mtnp.UpdateTableArray
- duplicate(boolean) - Method in class ca.uqac.lif.cep.mtnp.UpdateTableMap
- duplicate(boolean) - Method in class ca.uqac.lif.cep.mtnp.UpdateTableStream
- duplicate(boolean) - Method in class ca.uqac.lif.cep.serialization.DeserializeEvents
- duplicate(boolean) - Method in class ca.uqac.lif.cep.serialization.SerializeEvents
- duplicate(boolean) - Method in class ca.uqac.lif.cep.signal.Limit
- duplicate(boolean) - Method in class ca.uqac.lif.cep.signal.Noise
- duplicate(boolean) - Method in class ca.uqac.lif.cep.signal.PeakFinderLocalMaximum
- duplicate(boolean) - Method in class ca.uqac.lif.cep.signal.PeakFinderTravelRise
- duplicate(boolean) - Method in class ca.uqac.lif.cep.signal.Persist
- duplicate(boolean) - Method in class ca.uqac.lif.cep.signal.PlateauFinder
- duplicate(boolean) - Method in class ca.uqac.lif.cep.signal.Smooth.ArrayAverage
- duplicate(boolean) - Method in class ca.uqac.lif.cep.signal.Threshold
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.Blow
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.ExpandAsColumns
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.FetchAttribute
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.FromFunction
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.GetAttribute
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.JoinSet
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.MergeScalars
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.MergeTuples
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.ProjectTuple
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.RegexTupleBuilder
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.ScalarIntoTuple
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.TransposePair
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.Tuple
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.TupleFeeder
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.TupleMap
- duplicate(boolean) - Method in class ca.uqac.lif.cep.tuples.Where
- duplicate(boolean) - Method in class ca.uqac.lif.cep.widgets.GetWidgetValue
- duplicate(boolean) - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- duplicate(boolean) - Method in class ca.uqac.lif.cep.widgets.WidgetSink
- duplicate(boolean) - Method in class ca.uqac.lif.cep.xml.XPathFunction
- duplicate(boolean) - Method in class ca.uqac.lif.cep.xml.XPathFunctionGetNumber
- duplicate(boolean) - Method in class ca.uqac.lif.cep.xml.XPathFunctionGetText
E
- encapsulate(Processor) - Static method in class ca.uqac.lif.cep.dsl.GroupProcessorBuilder
-
Encapsulates a processor into a group processor
- endOfFileVisit() - Method in class ca.uqac.lif.cep.dsl.MultilineGroupProcessorBuilder
- entrySet() - Method in class ca.uqac.lif.cep.tuples.CacheMap
- entrySet() - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- entrySet() - Method in class ca.uqac.lif.cep.tuples.TupleMap
- equals(Object) - Method in class ca.uqac.lif.cep.fol.Predicate.PredicateArgument
- equals(Object) - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- equals(Object) - Method in class ca.uqac.lif.cep.tuples.TupleMap
- escape(String) - Static method in class ca.uqac.lif.cep.provenance.DotProvenanceTreeRenderer
- evaluate(Object[], Object[]) - Method in class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- evaluate(Object[], Object[]) - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction
- evaluate(Object[], Object[]) - Method in class ca.uqac.lif.cep.fol.PredicateAssertion
- evaluate(Object[], Object[]) - Method in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- evaluate(Object[], Object[]) - Method in class ca.uqac.lif.cep.serialization.DeserializeEvents
- evaluate(Object[], Object[]) - Method in class ca.uqac.lif.cep.tuples.FromFunction
- evaluate(Object[], Object[]) - Method in class ca.uqac.lif.cep.tuples.MergeScalars
- evaluate(Object[], Object[]) - Method in class ca.uqac.lif.cep.tuples.MergeTuples
- evaluate(Object[], Object[]) - Method in class ca.uqac.lif.cep.xml.XPathFunction
- evaluate(Object[], Object[], Context) - Method in class ca.uqac.lif.cep.fol.Predicate.Wildcard
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.fol.Predicate
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.fol.PredicateAssertion
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.serialization.DeserializeEvents
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.serialization.SerializeEvents
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.signal.Smooth.ArrayAverage
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.tuples.FromFunction
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.tuples.MergeScalars
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.tuples.MergeTuples
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.tuples.ProjectTuple
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.widgets.GetWidgetValue
- evaluate(Object[], Object[], Context, EventTracker) - Method in class ca.uqac.lif.cep.xml.XPathFunction
- evaluatePlaceholders(XPathExpression, Context, EventTracker) - Static method in class ca.uqac.lif.cep.xml.XPathFunction
-
Replaces all occurrences of placeholders in an XPath expression by concrete values fetched from some context.
- EventFunction - Class in ca.uqac.lif.cep.provenance
-
Node function that relates to an event at a specific position, in a specific stream of a specific processor.
- EventFunction() - Constructor for class ca.uqac.lif.cep.provenance.EventFunction
-
Empty constructor.
- EventFunction(int, int, int) - Constructor for class ca.uqac.lif.cep.provenance.EventFunction
-
Creates a new event function.
- EventFunction.InputValue - Class in ca.uqac.lif.cep.provenance
- EventFunction.OutputValue - Class in ca.uqac.lif.cep.provenance
- execute() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- executeQuery() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- executeQuery(String) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepStatement
- executeQuery(String) - Method in interface ca.uqac.lif.cep.jdbc.Interpreter
-
Executes a query
- executeUpdate() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- Exists - Class in ca.uqac.lif.cep.fol
-
Function that acts as a first-order existential quantifier.
- Exists(String, Function) - Constructor for class ca.uqac.lif.cep.fol.Exists
- Exists(String, Function, Function) - Constructor for class ca.uqac.lif.cep.fol.Exists
- ExistsInterpretation - Class in ca.uqac.lif.cep.fol
- ExistsInterpretation(String, String, Function) - Constructor for class ca.uqac.lif.cep.fol.ExistsInterpretation
- ExpandAsColumns - Class in ca.uqac.lif.cep.tuples
-
Transforms a tuple by replacing two key-value pairs by a single new key-value pair.
- ExpandAsColumns(String, String) - Constructor for class ca.uqac.lif.cep.tuples.ExpandAsColumns
-
Creates a new instance of the function.
- expandInputs(ProvenanceNode, int) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
F
- FetchAttribute - Class in ca.uqac.lif.cep.tuples
-
Gets the value of an attribute in a
Tuple
- FetchAttribute(String) - Constructor for class ca.uqac.lif.cep.tuples.FetchAttribute
-
Creates a new instance of the function
- fetchOrCreateProvenanceNode(int, int, int) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
-
Fetches the
ProvenanceNode
for a given processor/index/position triplet. - fetchProvenanceNode(int, int, int) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
-
Fetches the
ProvenanceNode
for a given processor/index/position triplet. - fetchWidgettValue(Object, Object[]) - Method in class ca.uqac.lif.cep.widgets.GetWidgetValue
- FileHibernate - Class in ca.uqac.lif.cep.hibernate
-
A
Hibernate
processor that saves its internal processor into a local file. - FileHibernate(Processor, String, ObjectPrinter<String>, ObjectReader<String>) - Constructor for class ca.uqac.lif.cep.hibernate.FileHibernate
-
Creates a new file hibernate processor.
- findDrops(boolean) - Method in class ca.uqac.lif.cep.signal.PeakFinderLocalMaximum
-
Sets whether the peak finder detects drops or peaks.
- fire(MooreMachine.Transition, Object[], Object[]) - Method in class ca.uqac.lif.cep.fsm.MooreMachine
-
Fires a transition and updates the machine's state
- fire(HttpExchange) - Method in class ca.uqac.lif.cep.http.HttpDownstreamGateway.ListenerCallback
- fire(HttpExchange) - Method in class ca.uqac.lif.cep.http.HttpSource.ListenerCallback
- fire(HttpExchange) - Method in class ca.uqac.lif.cep.http.HttpUpstreamGateway.PullCallback
- FirstOrderQuantifier - Class in ca.uqac.lif.cep.fol
- FirstOrderQuantifier(String, Function) - Constructor for class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- FirstOrderQuantifier(String, Function, Function) - Constructor for class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- FixedTupleBuilder - Class in ca.uqac.lif.cep.tuples
-
Utility class to create instances of tuples with a fixed schema
- FixedTupleBuilder(String...) - Constructor for class ca.uqac.lif.cep.tuples.FixedTupleBuilder
- ForAll - Class in ca.uqac.lif.cep.fol
-
Function that acts as a first-order universal quantifier.
- ForAll(String, Function) - Constructor for class ca.uqac.lif.cep.fol.ForAll
- ForAll(String, Function, Function) - Constructor for class ca.uqac.lif.cep.fol.ForAll
- ForAllInterpretation - Class in ca.uqac.lif.cep.fol
- ForAllInterpretation(String, String, Function) - Constructor for class ca.uqac.lif.cep.fol.ForAllInterpretation
- forkInput(Object) - Method in class ca.uqac.lif.cep.dsl.GroupProcessorBuilder
- From - Class in ca.uqac.lif.cep.tuples
-
Creates an
TupleExpression
from a set of input tuples and an array of names. - From(FromFunction) - Constructor for class ca.uqac.lif.cep.tuples.From
- FromFunction - Class in ca.uqac.lif.cep.tuples
-
The internal function performing the actual work for the
From
processor. - FromFunction(String...) - Constructor for class ca.uqac.lif.cep.tuples.FromFunction
- FunctionTransition - Class in ca.uqac.lif.cep.fsm
-
Transition for a Moore Machine where the guard is a function returning a
boolean
, and the context modification is a list ofContextAssignment
s. - FunctionTransition(FunctionTransition) - Constructor for class ca.uqac.lif.cep.fsm.FunctionTransition
- FunctionTransition(Function, int) - Constructor for class ca.uqac.lif.cep.fsm.FunctionTransition
- FunctionTransition(Function, int, ContextAssignment) - Constructor for class ca.uqac.lif.cep.fsm.FunctionTransition
- FunctionTransition(Function, int, ContextAssignment...) - Constructor for class ca.uqac.lif.cep.fsm.FunctionTransition
G
- get(int) - Method in class ca.uqac.lif.cep.fol.Predicate.PredicateArgument
- get(Object) - Method in class ca.uqac.lif.cep.tuples.CacheMap
- get(Object) - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- get(Object) - Method in class ca.uqac.lif.cep.tuples.TupleMap
- get(String) - Method in class ca.uqac.lif.cep.apache.HttpRequest
-
Gets the value of a parameter in the HTTP request
- GET - ca.uqac.lif.cep.apache.HttpRequest.Method
- getArgument(int) - Method in class ca.uqac.lif.cep.fol.PredicateTuple
-
Retrieves the n-th argument of the tuple
- getAttribute(String) - Method in class ca.uqac.lif.cep.tuples.AttributeGroup
-
Gets the value of an attribute by giving its name.
- getAttribute(String, String) - Method in class ca.uqac.lif.cep.tuples.AttributeGroup
-
Gets the value of an attribute by giving its name and the of the tuple it comes from.
- GetAttribute - Class in ca.uqac.lif.cep.tuples
-
Gets the value of an attribute in an
AttributeGroup
- GetAttribute(String) - Constructor for class ca.uqac.lif.cep.tuples.GetAttribute
-
Creates a new instance of the function
- GetAttribute(String, String) - Constructor for class ca.uqac.lif.cep.tuples.GetAttribute
-
Creates a new instance of the function
- getAttributeName() - Method in class ca.uqac.lif.cep.tuples.FetchAttribute
-
Gets the name of the attribute to get
- getAttributeName() - Method in class ca.uqac.lif.cep.tuples.GetAttribute
-
Gets the name of the attribute to get
- getBytes() - Method in class ca.uqac.lif.cep.provenance.CommandRunner
-
Gets the contents of stdout sent by the command as an array of bytes
- getBytes() - Method in class ca.uqac.lif.cep.provenance.CommandRunner.StreamGobbler
-
Returns the contents captured by the gobbler as an array of bytes
- getConnection(Map<Integer, Map<Integer, IndexEventTracker.ProcessorConnection>>, int, int) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
- getCopy(boolean) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
- getCount() - Method in class ca.uqac.lif.cep.diagnostics.PassthroughCounter
-
Returns the number of events that went through the processor
- getDataPointId() - Method in class ca.uqac.lif.cep.provenance.EventFunction.InputValue
- getDataPointId() - Method in class ca.uqac.lif.cep.provenance.EventFunction.OutputValue
- getDestination() - Method in class ca.uqac.lif.cep.fsm.FunctionTransition
- getDestination() - Method in class ca.uqac.lif.cep.fsm.MooreMachine.Transition
-
Gets the destination (i.e.
- getDestination() - Method in class ca.uqac.lif.cep.fsm.ProcessorTransition
- getDomain(String) - Method in class ca.uqac.lif.cep.fol.Interpretation
-
Gets the set of values of the given domain
- GetDomain - Class in ca.uqac.lif.cep.fol
-
Function taking an interpretation as its input, and returning the set of values associated with some domain as its output.
- GetDomain(String) - Constructor for class ca.uqac.lif.cep.fol.GetDomain
-
Creates a new instance of domain function
- getDomainNames() - Method in class ca.uqac.lif.cep.fol.Predicate
- getDouble(String) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepResultSet
- getErrorCode() - Method in class ca.uqac.lif.cep.provenance.CommandRunner
-
Gets the return code of the command.
- getFilename(Processor, String) - Static method in class ca.uqac.lif.cep.hibernate.FileHibernate
-
Creates a filename from a pattern expression and the processor's current context.
- getFloat(String) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepResultSet
- getFork(Object) - Method in class ca.uqac.lif.cep.dsl.GroupProcessorBuilder
- getFridge() - Method in class ca.uqac.lif.cep.hibernate.Hibernate
-
Gets an instance of fridge
- getImpactTree(int, int, int) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
-
Gets the impact tree for a given event.
- getIndexOf(String) - Method in class ca.uqac.lif.cep.tuples.CacheMap
-
Get the index of a key in the current map
- getIndexOf(String) - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- getIndexOf(String, int, T) - Method in class ca.uqac.lif.cep.tuples.CacheMap
-
Retrieves a value, possibly using an index.
- getIndices(ProvenanceNode) - Static method in class ca.uqac.lif.cep.provenance.ProvenanceTree
- getIndices(ProvenanceNode, List<Integer>) - Static method in class ca.uqac.lif.cep.provenance.ProvenanceTree
- getInputArity() - Method in class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- getInputArity() - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction
- getInputArity() - Method in class ca.uqac.lif.cep.fol.Predicate
- getInputArity() - Method in class ca.uqac.lif.cep.fol.PredicateAssertion
- getInputArity() - Method in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- getInputArity() - Method in class ca.uqac.lif.cep.serialization.DeserializeEvents
- getInputArity() - Method in class ca.uqac.lif.cep.serialization.SerializeEvents
- getInputArity() - Method in class ca.uqac.lif.cep.signal.Smooth.ArrayAverage
- getInputArity() - Method in class ca.uqac.lif.cep.tuples.FromFunction
- getInputArity() - Method in class ca.uqac.lif.cep.tuples.MergeScalars
- getInputArity() - Method in class ca.uqac.lif.cep.tuples.MergeTuples
- getInputArity() - Method in class ca.uqac.lif.cep.tuples.ProjectTuple
- getInputArity() - Method in class ca.uqac.lif.cep.widgets.GetWidgetValue
- getInputArity() - Method in class ca.uqac.lif.cep.xml.XPathFunction
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.fol.Predicate
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.fol.PredicateAssertion
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.serialization.DeserializeEvents
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.serialization.JsonDeserialize
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.serialization.JsonDeserializeString
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.serialization.JsonSerialize
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.serialization.JsonSerializeString
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.serialization.SerializeEvents
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.signal.Smooth.ArrayAverage
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.tuples.FromFunction
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.tuples.MergeScalars
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.tuples.MergeTuples
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.tuples.ProjectTuple
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.widgets.GetWidgetValue
- getInputTypesFor(Set<Class<?>>, int) - Method in class ca.uqac.lif.cep.xml.XPathFunction
- getInt(String) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepResultSet
- getKey() - Method in class ca.uqac.lif.cep.tuples.Tuple.MapEntry
- getLeaves(ProvenanceNode) - Static method in class ca.uqac.lif.cep.provenance.ProvenanceTree
- getLeaves(ProvenanceNode, List<ProvenanceNode>) - Static method in class ca.uqac.lif.cep.provenance.ProvenanceTree
- getMajorVersion() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepDriver
- getMaxValue() - Method in class ca.uqac.lif.cep.signal.WindowProcessor
- getMetaData() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- getMethod() - Method in class ca.uqac.lif.cep.apache.HttpRequest
-
Gets the method of this HTTP request
- getMinorVersion() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepDriver
- getMinValue() - Method in class ca.uqac.lif.cep.signal.WindowProcessor
- getName() - Method in class ca.uqac.lif.cep.fol.PredicateTuple
-
Gets the name of the predicate this tuple defines
- getName() - Method in class ca.uqac.lif.cep.tuples.AttributeExpression
-
Gets the attribute name given to that expression
- getOutputArity() - Method in class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- getOutputArity() - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction
- getOutputArity() - Method in class ca.uqac.lif.cep.fol.Predicate
- getOutputArity() - Method in class ca.uqac.lif.cep.fol.PredicateAssertion
- getOutputArity() - Method in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- getOutputArity() - Method in class ca.uqac.lif.cep.serialization.DeserializeEvents
- getOutputArity() - Method in class ca.uqac.lif.cep.serialization.SerializeEvents
- getOutputArity() - Method in class ca.uqac.lif.cep.signal.Smooth.ArrayAverage
- getOutputArity() - Method in class ca.uqac.lif.cep.tuples.FromFunction
- getOutputArity() - Method in class ca.uqac.lif.cep.tuples.MergeScalars
- getOutputArity() - Method in class ca.uqac.lif.cep.tuples.MergeTuples
- getOutputArity() - Method in class ca.uqac.lif.cep.tuples.ProjectTuple
- getOutputArity() - Method in class ca.uqac.lif.cep.widgets.GetWidgetValue
- getOutputArity() - Method in class ca.uqac.lif.cep.xml.XPathFunction
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.fol.Predicate
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.fol.PredicateAssertion
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.serialization.DeserializeEvents
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.serialization.SerializeEvents
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.signal.Smooth.ArrayAverage
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.tuples.FromFunction
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.tuples.MergeScalars
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.tuples.MergeTuples
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.tuples.ProjectTuple
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.tuples.Select.SelectFunction
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.widgets.GetWidgetValue
- getOutputTypeFor(int) - Method in class ca.uqac.lif.cep.xml.XPathFunction
- GetParameter(String) - Constructor for class ca.uqac.lif.cep.apache.HttpRequest.GetParameter
- getParameterMetaData() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- getParameters() - Method in class ca.uqac.lif.cep.apache.HttpRequest
-
Returns the parameters associated with this HTTP request
- getParentLogger() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepDriver
- getPath() - Method in class ca.uqac.lif.cep.apache.HttpRequest
-
Gets the path of this HTTP request
- getPeakPosition() - Method in class ca.uqac.lif.cep.signal.PeakFinderLocalMaximum
- getPlot() - Method in class ca.uqac.lif.cep.mtnp.DrawPlot
- getPlot() - Method in class ca.uqac.lif.cep.mtnp.PrintGnuPlot
- getPredicate(String) - Method in class ca.uqac.lif.cep.fol.Interpretation
-
Gets the predicate instance of given name
- getProcessorId() - Method in class ca.uqac.lif.cep.provenance.EventFunction
-
Gets the processor ID associated to this event function
- getPropertyInfo(String, Properties) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepDriver
- getProvenanceTree(int, int, int) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
-
Gets the provenance tree for a given event.
- getProvenanceTree(Processor, int, int) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
-
Gets the provenance tree for a given event.
- getResponseCode() - Method in class ca.uqac.lif.cep.apache.HttpRequest
-
Gets the response code of this HTTP request
- getResponseSize() - Method in class ca.uqac.lif.cep.apache.HttpRequest
-
Gets the size of the response to this HTTP request
- getSize() - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
-
Returns the size of this tracker.
- getSource(String) - Method in class ca.uqac.lif.cep.json.SpliceJsonStreamSource
- getSource(String) - Method in class ca.uqac.lif.cep.tuples.SpliceTupleSource
- getSourceIp() - Method in class ca.uqac.lif.cep.apache.HttpRequest
-
Gets the source IP address of this HTTP request
- getState() - Method in class ca.uqac.lif.cep.fsm.MooreMachine
- getStreamIndex() - Method in class ca.uqac.lif.cep.provenance.EventFunction
-
Gets the stream index associated to this event function
- getStreamPosition() - Method in class ca.uqac.lif.cep.provenance.EventFunction
-
Gets the stream position associated to this event function
- getString() - Method in class ca.uqac.lif.cep.provenance.CommandRunner
-
Gets the contents of stdout sent by the command as a string
- getString(String) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepResultSet
- getTimestamp() - Method in class ca.uqac.lif.cep.apache.HttpRequest
-
Gets the timestamp of this request
- getTraceName() - Method in class ca.uqac.lif.cep.tuples.GetAttribute
-
Gets the name of the trace to get the attribute from
- getUser() - Method in class ca.uqac.lif.cep.apache.HttpRequest
-
Gets the user associated to this HTTP request
- getValue() - Method in class ca.uqac.lif.cep.tuples.Tuple.MapEntry
- getValue(byte[]) - Method in class ca.uqac.lif.cep.widgets.ToImageIcon
- getValue(int) - Method in class ca.uqac.lif.cep.tuples.CacheMap
- getValue(int) - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- getValue(HttpRequest) - Method in class ca.uqac.lif.cep.apache.HttpRequest.GetParameter
- getValue(HttpRequest) - Method in class ca.uqac.lif.cep.apache.HttpRequest.GetPath
- getValue(HttpRequest) - Method in class ca.uqac.lif.cep.apache.HttpRequest.GetTimestamp
- getValue(HttpRequest, Number) - Method in class ca.uqac.lif.cep.apache.HttpRequest.RequestIsAfter
- getValue(Interpretation) - Method in class ca.uqac.lif.cep.fol.GetDomain
- getValue(Interpretation) - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction.DummyInterpretationFunction
- getValue(PredicateTuple) - Method in class ca.uqac.lif.cep.fol.PredicateGet
- getValue(PredicateTuple) - Method in class ca.uqac.lif.cep.fol.PredicateGetNumber
- getValue(AttributeGroup) - Method in class ca.uqac.lif.cep.tuples.AttributeExpression
-
Gets the value associated to the attribute name
- getValue(AttributeGroup) - Method in class ca.uqac.lif.cep.tuples.GetAttribute
- getValue(AttributeGroup) - Method in class ca.uqac.lif.cep.tuples.Select.SelectFunction
- getValue(Tuple) - Method in class ca.uqac.lif.cep.tuples.AppendToTuple
- getValue(Tuple) - Method in class ca.uqac.lif.cep.tuples.Blow
- getValue(Tuple) - Method in class ca.uqac.lif.cep.tuples.ExpandAsColumns
- getValue(Tuple) - Method in class ca.uqac.lif.cep.tuples.FetchAttribute
- getValue(Tuple) - Method in class ca.uqac.lif.cep.tuples.TransposePair
- getValue(JsonElement) - Method in class ca.uqac.lif.cep.json.JPathFunction
- getValue(JsonElement) - Method in class ca.uqac.lif.cep.json.NumberValue
- getValue(JsonElement) - Method in class ca.uqac.lif.cep.json.StringValue
- getValue(XmlElement) - Method in class ca.uqac.lif.cep.xml.XPathFunction
- getValue(Object) - Method in class ca.uqac.lif.cep.fol.PredicateTupleConversion
- getValue(Object) - Method in class ca.uqac.lif.cep.tuples.MapToTuple
- getValue(Object) - Method in class ca.uqac.lif.cep.tuples.NamedMapPlaceholder
- getValue(Object) - Method in class ca.uqac.lif.cep.tuples.ScalarIntoTuple
- getValue(String) - Method in class ca.uqac.lif.cep.apache.ParseCommonLog
- getValue(String) - Method in class ca.uqac.lif.cep.json.ParseJson
- getValue(String) - Method in class ca.uqac.lif.cep.xml.ParseXml
- getValue(EventObject) - Method in class ca.uqac.lif.cep.widgets.MouseCoordinates
- getValue(Set) - Method in class ca.uqac.lif.cep.tuples.JoinSet
- getVerdict(Object[][], Object[]) - Method in class ca.uqac.lif.cep.fol.Exists
- getVerdict(Object[][], Object[]) - Method in class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- getVerdict(Object[][], Object[]) - Method in class ca.uqac.lif.cep.fol.ForAll
- getWebSocketClient() - Method in class ca.uqac.lif.cep.io.websocket.WebSocketReader
-
Gets an instance of web socket client associated to this processor
- GetWidgetValue - Class in ca.uqac.lif.cep.widgets
- GrammarObjectBuilder<T> - Class in ca.uqac.lif.cep.dsl
- GrammarObjectBuilder() - Constructor for class ca.uqac.lif.cep.dsl.GrammarObjectBuilder
- GroupProcessorBuilder - Class in ca.uqac.lif.cep.dsl
-
A special type of
GrammarObjectBuilder
that encapsulates the resulting chain into aGroupProcessor
. - GroupProcessorBuilder() - Constructor for class ca.uqac.lif.cep.dsl.GroupProcessorBuilder
H
- hashCode() - Method in class ca.uqac.lif.cep.fol.Predicate.PredicateArgument
- hashCode() - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- hashCode() - Method in class ca.uqac.lif.cep.tuples.TupleMap
- Hibernate - Class in ca.uqac.lif.cep.hibernate
-
Stores an internal processor using an object fridge.
- Hibernate(Processor, Fridge) - Constructor for class ca.uqac.lif.cep.hibernate.Hibernate
-
Creates a new hibernate processor
- HttpDownstreamGateway - Class in ca.uqac.lif.cep.http
-
Outputs character strings received over the network from an upstream connection.
- HttpDownstreamGateway(int, String, RequestCallback.Method) - Constructor for class ca.uqac.lif.cep.http.HttpDownstreamGateway
-
Creates a new downstream gateway.
- HttpDownstreamGateway(int, String, RequestCallback.Method, String) - Constructor for class ca.uqac.lif.cep.http.HttpDownstreamGateway
-
Creates a new downstream gateway.
- HttpDownstreamGateway.ListenerCallback - Class in ca.uqac.lif.cep.http
- HttpGateway - Class in ca.uqac.lif.cep.http
-
Utility methods for handling HTTP requests.
- HttpRequest - Class in ca.uqac.lif.cep.apache
-
Representation of an HTTP request, as logged by an Apache server
- HttpRequest(String, String, String, long, HttpRequest.Method, String, Map<String, String>, int, int) - Constructor for class ca.uqac.lif.cep.apache.HttpRequest
-
Creates a new HTTP request event
- HttpRequest.GetParameter - Class in ca.uqac.lif.cep.apache
-
Function to get the path of an HTTP request
- HttpRequest.GetPath - Class in ca.uqac.lif.cep.apache
-
Function to get the path of an HTTP request
- HttpRequest.GetTimestamp - Class in ca.uqac.lif.cep.apache
-
Function to get the timestamp of an HTTP request
- HttpRequest.Method - Enum in ca.uqac.lif.cep.apache
-
The HTTP method used in the request
- HttpRequest.RequestIsAfter - Class in ca.uqac.lif.cep.apache
-
Function to compare the request's time with another time
- HttpSource - Class in ca.uqac.lif.cep.http
-
HTTP server that pulls events from upstream when it receives a GET request.
- HttpSource(String, int, CallbackResponse.ContentType) - Constructor for class ca.uqac.lif.cep.http.HttpSource
- HttpSource.ListenerCallback - Class in ca.uqac.lif.cep.http
- HttpUpstreamGateway - Class in ca.uqac.lif.cep.http
-
Sends character strings over the network through HTTP requests.
- HttpUpstreamGateway(String) - Constructor for class ca.uqac.lif.cep.http.HttpUpstreamGateway
- HttpUpstreamGateway(String, RequestCallback.Method, String, int) - Constructor for class ca.uqac.lif.cep.http.HttpUpstreamGateway
- HttpUpstreamGateway.PullCallback - Class in ca.uqac.lif.cep.http
-
Server callback that fires when the URL for this upstream gateway receives a request for events
I
- Implies(Function, Function) - Constructor for class ca.uqac.lif.cep.fol.LazyBooleanFunction.Implies
- includesLast(boolean) - Method in class ca.uqac.lif.cep.complex.RangeCep
-
Sets whether the event that determines the end boundary of the range should be included (i.e.
- IndexEventTracker - Class in ca.uqac.lif.cep.provenance
-
Tracks the relationship between output events produced by processors, and the input events that were used to compute them.
- IndexEventTracker() - Constructor for class ca.uqac.lif.cep.provenance.IndexEventTracker
- IndexEventTracker.ProcessorConnection - Class in ca.uqac.lif.cep.provenance
- InputValue(int, int, int) - Constructor for class ca.uqac.lif.cep.provenance.EventFunction.InputValue
- instance - Static variable in class ca.uqac.lif.cep.apache.HttpRequest.GetPath
- instance - Static variable in class ca.uqac.lif.cep.apache.HttpRequest.GetTimestamp
- instance - Static variable in class ca.uqac.lif.cep.apache.HttpRequest.RequestIsAfter
- instance - Static variable in class ca.uqac.lif.cep.apache.ParseCommonLog
- instance - Static variable in class ca.uqac.lif.cep.fol.LazyBooleanFunction.DummyInterpretationFunction
- instance - Static variable in class ca.uqac.lif.cep.fol.Predicate.Wildcard
- instance - Static variable in class ca.uqac.lif.cep.fol.PredicateTupleConversion
- instance - Static variable in class ca.uqac.lif.cep.json.NumberValue
- instance - Static variable in class ca.uqac.lif.cep.json.ParseJson
-
Instance of the function
- instance - Static variable in class ca.uqac.lif.cep.json.StringValue
- instance - Static variable in class ca.uqac.lif.cep.tuples.Blow
- instance - Static variable in class ca.uqac.lif.cep.tuples.MapToTuple
- instance - Static variable in class ca.uqac.lif.cep.widgets.GetWidgetValue
-
A single visible instance of the function
- instance - Static variable in class ca.uqac.lif.cep.widgets.MouseCoordinates
- instance - Static variable in class ca.uqac.lif.cep.widgets.ToImageIcon
- instance - Static variable in class ca.uqac.lif.cep.xml.ParseXml
-
Instance of the function
- Interpretation - Class in ca.uqac.lif.cep.fol
-
A context in which predicates can be evaluated.
- Interpretation() - Constructor for class ca.uqac.lif.cep.fol.Interpretation
-
Creates a new empty interpretation
- Interpretation(Interpretation) - Constructor for class ca.uqac.lif.cep.fol.Interpretation
-
Creates a copy of an interpretation
- Interpretation(Map<String, Set<Object>>, Map<String, Predicate>) - Constructor for class ca.uqac.lif.cep.fol.Interpretation
-
Creates a new interpretation
- InterpretationBuilder - Class in ca.uqac.lif.cep.fol
- InterpretationBuilder() - Constructor for class ca.uqac.lif.cep.fol.InterpretationBuilder
- Interpreter - Interface in ca.uqac.lif.cep.jdbc
-
Generic object that can be used to parse string "queries" and return an iterable result
- Interpreter.ParseException - Exception in ca.uqac.lif.cep.jdbc
-
An exception thrown if the query cannot be parsed by the interpreter
- isContiguous(boolean) - Method in class ca.uqac.lif.cep.complex.RangeCep
-
Sets whether the false event that marks the end of a range should count as the first event of a new range (i.e.
- isEmpty() - Method in class ca.uqac.lif.cep.tuples.CacheMap
- isEmpty() - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- isEmpty() - Method in class ca.uqac.lif.cep.tuples.TupleMap
- isFired(Object[], Context) - Method in class ca.uqac.lif.cep.fsm.FunctionTransition
- isFired(Object[], Context) - Method in class ca.uqac.lif.cep.fsm.MooreMachine.Transition
-
Determines if the transition fires for the given input
- isFired(Object[], Context) - Method in class ca.uqac.lif.cep.fsm.ProcessorTransition
- isFired(Object[], Context) - Method in class ca.uqac.lif.cep.fsm.TransitionOtherwise
- isValidURL(String) - Static method in class ca.uqac.lif.cep.jdbc.BeepBeepDriver
-
Validates a URL
J
- jdbcCompliant() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepDriver
- JdbcSource - Class in ca.uqac.lif.cep.jdbc
-
Converts a query to a database into a trace of named tuples.
- JdbcSource(Connection, String) - Constructor for class ca.uqac.lif.cep.jdbc.JdbcSource
-
Builds a JDBC source.
- JoinSet - Class in ca.uqac.lif.cep.tuples
-
Merges all tuples in a set with the same value for a given attribute.
- JoinSet(String) - Constructor for class ca.uqac.lif.cep.tuples.JoinSet
-
Creates a new join set function
- JPathFunction - Class in ca.uqac.lif.cep.json
-
Function that evaluates a JPath expression on a JsonElement
- JPathFunction(String) - Constructor for class ca.uqac.lif.cep.json.JPathFunction
-
Creates a new JPath function
- JPathFunction(List<JsonPath.PathElement>) - Constructor for class ca.uqac.lif.cep.json.JPathFunction
-
Creates a new XPath function
- JsonDeserialize<U> - Class in ca.uqac.lif.cep.serialization
-
Function that deserializes a JSON element into an object
- JsonDeserialize(Class<U>) - Constructor for class ca.uqac.lif.cep.serialization.JsonDeserialize
- JsonDeserializeString<U> - Class in ca.uqac.lif.cep.serialization
-
Function that deserializes a JSON string into an object
- JsonDeserializeString(Class<U>) - Constructor for class ca.uqac.lif.cep.serialization.JsonDeserializeString
- JsonLineFeeder - Class in ca.uqac.lif.cep.json
-
A source of JSON events taking its data from a JSON file.
- JsonLineFeeder(InputStream) - Constructor for class ca.uqac.lif.cep.json.JsonLineFeeder
-
Creates a new instance of the source, by providing an input stream to read text from.
- JsonSerialize - Class in ca.uqac.lif.cep.serialization
-
Function that serializes its input into a JSON element
- JsonSerialize() - Constructor for class ca.uqac.lif.cep.serialization.JsonSerialize
- JsonSerializeString - Class in ca.uqac.lif.cep.serialization
-
Function that serializes its input into a JSON string
- JsonSerializeString() - Constructor for class ca.uqac.lif.cep.serialization.JsonSerializeString
K
- keySet() - Method in class ca.uqac.lif.cep.tuples.CacheMap
- keySet() - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- keySet() - Method in class ca.uqac.lif.cep.tuples.TupleMap
L
- LazyBooleanFunction - Class in ca.uqac.lif.cep.fol
- LazyBooleanFunction(boolean, Function, Function) - Constructor for class ca.uqac.lif.cep.fol.LazyBooleanFunction
- LazyBooleanFunction.And - Class in ca.uqac.lif.cep.fol
- LazyBooleanFunction.DummyInterpretationFunction - Class in ca.uqac.lif.cep.fol
- LazyBooleanFunction.Implies - Class in ca.uqac.lif.cep.fol
- LazyBooleanFunction.Or - Class in ca.uqac.lif.cep.fol
- Limit - Class in ca.uqac.lif.cep.signal
-
Outputs at most one non-zero event in an interval of width n.
- Limit() - Constructor for class ca.uqac.lif.cep.signal.Limit
- Limit(int) - Constructor for class ca.uqac.lif.cep.signal.Limit
- ListenerCallback() - Constructor for class ca.uqac.lif.cep.http.HttpDownstreamGateway.ListenerCallback
- ListenerCallback() - Constructor for class ca.uqac.lif.cep.http.HttpSource.ListenerCallback
- ListenerSource - Class in ca.uqac.lif.cep.widgets
-
A
Source
processor that can be added as anActionListener
to an AWT or Swing widget. - ListenerSource() - Constructor for class ca.uqac.lif.cep.widgets.ListenerSource
-
Creates a new action listener source
M
- m_allowRestarts - Variable in class ca.uqac.lif.cep.complex.RangeCep
-
A flag that determines if more than one complex event can be produced (default:
false
). - m_arguments - Variable in class ca.uqac.lif.cep.fol.PredicateAssertion
-
The arguments of this predicate
- m_arguments - Variable in class ca.uqac.lif.cep.fol.PredicateTuple
-
The arguments of this predicate tuple
- m_assignments - Variable in class ca.uqac.lif.cep.fsm.FunctionTransition
- m_attributeNames - Variable in class ca.uqac.lif.cep.tuples.MergeScalars
-
The names given to the attributes corresponding to each scalar
- m_attributeNames - Variable in class ca.uqac.lif.cep.tuples.RegexTupleBuilder
-
The name given to each capture block in the output tuples
- m_builder - Variable in class ca.uqac.lif.cep.tuples.MergeScalars
- m_builder - Variable in class ca.uqac.lif.cep.tuples.MergeTuples
-
A helper class to build instances of the merged tuples
- m_builder - Variable in class ca.uqac.lif.cep.tuples.ProjectTuple
-
The builder used to create the output tuples
- m_builder - Variable in class ca.uqac.lif.cep.tuples.TupleFeeder
-
The builder object used to create tuples
- m_calendar - Variable in class ca.uqac.lif.cep.apache.ParseCommonLog
-
An instance of calendar to convert dates into timestamps
- m_callback - Variable in class ca.uqac.lif.cep.diagnostics.PassthroughCounter
-
A callback to call (if any)
- m_callback - Variable in class ca.uqac.lif.cep.diagnostics.ThroughputMeter
- m_callback - Variable in class ca.uqac.lif.cep.diagnostics.Timer
- m_columnHeader - Variable in class ca.uqac.lif.cep.tuples.TransposePair
-
The key associated to the tuple's header
- m_columnName - Variable in class ca.uqac.lif.cep.tuples.ExpandAsColumns
-
The name of the column whose value will be used as a column header
- m_columnValue - Variable in class ca.uqac.lif.cep.tuples.ExpandAsColumns
-
The name of the column whose value will be used as a value for the newly created column
- m_columnValue - Variable in class ca.uqac.lif.cep.tuples.TransposePair
-
The key associated to the tuple's value
- m_command - Variable in class ca.uqac.lif.cep.provenance.CommandRunner
- m_commentChar - Variable in class ca.uqac.lif.cep.dsl.MultilineGroupProcessorBuilder
-
A character used to mark comment lines
- m_complexEventFunction - Variable in class ca.uqac.lif.cep.complex.RangeCep
-
The function that is called when the end of the range is reached, and which is used to create the complex output event.
- m_component - Variable in class ca.uqac.lif.cep.widgets.WidgetSink
-
The component on which the input events are displayed
- m_condition - Variable in class ca.uqac.lif.cep.tuples.Where
-
The condition to evaluate.
- m_connection - Variable in class ca.uqac.lif.cep.jdbc.JdbcSource
-
The database connection object
- m_contents - Variable in class ca.uqac.lif.cep.tuples.TupleMap
-
The contents of the named tuple
- m_contiguous - Variable in class ca.uqac.lif.cep.complex.RangeCep
-
A flag that determines if the false event that marks the end of a range should count as the first event of a new range (i.e.
- m_counter - Variable in class ca.uqac.lif.cep.signal.Limit
- m_currentState - Variable in class ca.uqac.lif.cep.complex.RangeCep
-
The current state of the range.
- m_currentState - Variable in class ca.uqac.lif.cep.fsm.MooreMachine
-
The current state the machine is in
- m_dataProcessors - Variable in class ca.uqac.lif.cep.complex.RangeCep
-
An array of push units that evaluate the data processors.
- m_destination - Variable in class ca.uqac.lif.cep.fsm.FunctionTransition
- m_domainFunction - Variable in class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- m_domainName - Variable in class ca.uqac.lif.cep.fol.GetDomain
-
The name of the domain to fetch from the interpretation
- m_domainName - Variable in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- m_domainNames - Variable in class ca.uqac.lif.cep.fol.Predicate
-
The predicate's domain name for each of its arguments
- m_errorCode - Variable in class ca.uqac.lif.cep.provenance.CommandRunner
- m_eventCount - Variable in class ca.uqac.lif.cep.diagnostics.PassthroughCounter
-
The number of events that went through the processor
- m_eventsReceived - Variable in class ca.uqac.lif.cep.diagnostics.ThroughputMeter
- m_expression - Variable in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- m_expression - Variable in class ca.uqac.lif.cep.tuples.AttributeExpression
-
The expression to compute the output value
- m_expression - Variable in class ca.uqac.lif.cep.xml.XPathFunction
-
The XPath expression this function evaluates
- m_expressions - Variable in class ca.uqac.lif.cep.tuples.Select.SelectFunction
-
The expressions used to build the output tuple
- m_failFast - Variable in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- m_feedOneByOne - Variable in class ca.uqac.lif.cep.jdbc.JdbcSource
-
Whether the tuples of the underlying relation should be output one by one on every call to
JdbcSource.compute(Object[], Queue)
, or output all at once on the first call to that method. - m_fridge - Variable in class ca.uqac.lif.cep.hibernate.Hibernate
-
A fridge used to store the processor
- m_function - Variable in class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- m_function - Variable in class ca.uqac.lif.cep.fsm.FunctionTransition
- m_groups - Variable in class ca.uqac.lif.cep.provenance.IndexEventTracker
- m_hasRun - Variable in class ca.uqac.lif.cep.jdbc.JdbcSource
-
Remembers whether the query has already been run on the database
- m_identd - Variable in class ca.uqac.lif.cep.apache.HttpRequest
-
Remote identification of the user
- m_ids - Variable in class ca.uqac.lif.cep.provenance.DotProvenanceTreeRenderer
- m_includesLast - Variable in class ca.uqac.lif.cep.complex.RangeCep
-
A flag that determines if the event that determines the end boundary of the range should be included (i.e.
- m_initialAssignments - Variable in class ca.uqac.lif.cep.fsm.MooreMachine
-
The initial assignments given to each variable
- m_initialState - Variable in class ca.uqac.lif.cep.fsm.MooreMachine
-
The initial state of the machine
- m_inputArity - Variable in class ca.uqac.lif.cep.tuples.MergeTuples
-
The number of input tuples to merge
- m_inputArity - Variable in class ca.uqac.lif.cep.tuples.ProjectTuple
-
The function's input arity
- m_inputConnections - Variable in class ca.uqac.lif.cep.provenance.IndexEventTracker
- m_inputForks - Variable in class ca.uqac.lif.cep.dsl.GroupProcessorBuilder
- m_inputType - Variable in class ca.uqac.lif.cep.serialization.DeserializeEvents
-
A reference to the class of the serialized objects.
- m_interpretation - Variable in class ca.uqac.lif.cep.fol.InterpretationBuilder
- m_interpreter - Variable in class ca.uqac.lif.cep.jdbc.BeepBeepConnection
- m_interpreter - Variable in class ca.uqac.lif.cep.jdbc.BeepBeepStatement
-
An interpreter
- m_interval - Variable in class ca.uqac.lif.cep.diagnostics.PassthroughCounter
-
The interval to call the callback
- m_interval - Variable in class ca.uqac.lif.cep.diagnostics.Timer
- m_invert - Variable in class ca.uqac.lif.cep.signal.PeakFinderLocalMaximum
-
Whether to invert the values before computing.
- m_is - Variable in class ca.uqac.lif.cep.json.JsonLineFeeder
-
The input stream to read JSON content from.
- m_joinAttribute - Variable in class ca.uqac.lif.cep.tuples.JoinSet
-
The attribute over which to perform the join
- m_keyName - Variable in class ca.uqac.lif.cep.tuples.ScalarIntoTuple
-
The name given to the key for the resulting tuple
- m_lastIndex - Variable in class ca.uqac.lif.cep.tuples.NamedMapPlaceholder
- m_lastOccurrences - Variable in class ca.uqac.lif.cep.fsm.MooreMachine
-
A map storing the last event position for each state
- m_lastPlateauFound - Variable in class ca.uqac.lif.cep.signal.PlateauFinder
-
The value of the last plateau found.
- m_lastTuple - Variable in class ca.uqac.lif.cep.jdbc.BeepBeepResultSet
-
The last tuple return by a call to
Pullable.pull()
- m_lastValue - Variable in class ca.uqac.lif.cep.signal.Persist
- m_left - Variable in class ca.uqac.lif.cep.fol.LazyBooleanFunction
- m_limit - Variable in class ca.uqac.lif.cep.signal.Limit
- m_looplessPath - Variable in class ca.uqac.lif.cep.fsm.MooreMachine
-
A map storing the last loopless path
- m_mapping - Variable in class ca.uqac.lif.cep.provenance.IndexEventTracker
-
A map containing all the input-output associations recorded so far.
- m_maxValue - Variable in class ca.uqac.lif.cep.signal.WindowProcessor
-
The maximum value encountered so far
- m_method - Variable in class ca.uqac.lif.cep.apache.HttpRequest
-
The method used for the request (GET, POST)
- m_method - Variable in class ca.uqac.lif.cep.http.HttpDownstreamGateway
-
The HTTP method
- m_mimeType - Variable in class ca.uqac.lif.cep.http.HttpSource
-
The MIME type to declare when sending an HTTP response
- m_minValue - Variable in class ca.uqac.lif.cep.signal.WindowProcessor
-
The minimum value encountered so far
- m_name - Variable in class ca.uqac.lif.cep.fol.Predicate
-
The predicate's name
- m_name - Variable in class ca.uqac.lif.cep.fol.PredicateTuple
-
The name of the predicate this tuple defines
- m_name - Variable in class ca.uqac.lif.cep.tuples.NamedMapPlaceholder
- m_name - Variable in class ca.uqac.lif.cep.tuples.ProjectTuple.NameFunctionPair
- m_nodeCounter - Variable in class ca.uqac.lif.cep.provenance.DotProvenanceTreeRenderer
- m_numSincePeak - Variable in class ca.uqac.lif.cep.signal.PeakFinderLocalMaximum
-
The number of events that went out of the window since the last peak was seen.
- m_outputConnections - Variable in class ca.uqac.lif.cep.provenance.IndexEventTracker
- m_outputSymbols - Variable in class ca.uqac.lif.cep.fsm.MooreMachine
-
Associates output symbols to the states of the machine
- m_outputType - Variable in class ca.uqac.lif.cep.serialization.DeserializeEvents
-
A reference to the class of the serialized objects.
- m_outputType - Variable in class ca.uqac.lif.cep.serialization.SerializeEvents
-
A reference to the class of the serialized objects.
- m_outputType - Variable in class ca.uqac.lif.cep.xml.XPathFunctionGet
-
The type to cast the output to
- m_pairs - Variable in class ca.uqac.lif.cep.tuples.ProjectTuple
-
The list of associations between the output tuple's key and its corresponding value
- m_parameterName - Variable in class ca.uqac.lif.cep.apache.HttpRequest.GetParameter
-
The name of the parameter to get
- m_parameters - Variable in class ca.uqac.lif.cep.apache.HttpRequest
-
The parameters of this method
- m_parser - Variable in class ca.uqac.lif.cep.dsl.GrammarObjectBuilder
-
The parser used to parse expressions
- m_path - Variable in class ca.uqac.lif.cep.apache.HttpRequest
-
The path of the request
- m_pattern - Variable in class ca.uqac.lif.cep.tuples.RegexTupleBuilder
-
The regex pattern to look for
- m_peakPosition - Variable in class ca.uqac.lif.cep.signal.PeakFinderLocalMaximum
-
The position in the window where the highest value is
- m_plateauFound - Variable in class ca.uqac.lif.cep.signal.PlateauFinder
-
Whether an output event has been sent for the current plateau
- m_plot - Variable in class ca.uqac.lif.cep.mtnp.DrawPlot
- m_plot - Variable in class ca.uqac.lif.cep.mtnp.PrintGnuPlot
- m_port - Variable in class ca.uqac.lif.cep.http.HttpDownstreamGateway
-
The TCP port on which the gateway listens for requests
- m_port - Variable in class ca.uqac.lif.cep.http.HttpSource
-
The TCP port on which the gateway listens for requests
- m_position - Variable in class ca.uqac.lif.cep.fol.PredicateGet
-
The position to extract from each tuple
- m_position - Variable in class ca.uqac.lif.cep.fol.PredicateGetNumber
- m_predicateName - Variable in class ca.uqac.lif.cep.fol.PredicateAssertion
-
The name of the predicate to evaluate
- m_printer - Variable in class ca.uqac.lif.cep.hibernate.FileHibernate
-
The printer that is used to print to a file
- m_processorId - Variable in class ca.uqac.lif.cep.provenance.EventFunction
-
The ID of the processor which produces the event
- m_processors - Variable in class ca.uqac.lif.cep.diagnostics.Derivation
- m_processors - Variable in class ca.uqac.lif.cep.dsl.GroupProcessorBuilder
- m_procId - Variable in class ca.uqac.lif.cep.provenance.IndexEventTracker.ProcessorConnection
- m_pullable - Variable in class ca.uqac.lif.cep.http.HttpSource
-
A pullable to get events from
- m_pullable - Variable in class ca.uqac.lif.cep.jdbc.BeepBeepResultSet
-
The
Pullable
this result set will pull its results from - m_pullMethod - Variable in class ca.uqac.lif.cep.http.HttpUpstreamGateway
-
The method (GET or POST) that will be used when listening to the pull URL
- m_pullUrl - Variable in class ca.uqac.lif.cep.http.HttpDownstreamGateway
-
The URL to call when this processor is asked for a new event.
- m_pullUrl - Variable in class ca.uqac.lif.cep.http.HttpUpstreamGateway
-
The URL that the server will listen to for pull requests
- m_pushables - Variable in class ca.uqac.lif.cep.diagnostics.Derivation
- m_pushMethod - Variable in class ca.uqac.lif.cep.http.HttpUpstreamGateway
-
The method (GET or POST) that will be used when calling the push URL
- m_pushOnReceive - Variable in class ca.uqac.lif.cep.http.HttpDownstreamGateway
-
Whether this processor makes a call to
push()
when a request is received - m_pushUrl - Variable in class ca.uqac.lif.cep.http.HttpUpstreamGateway
-
The URL that will be called when events are pushed to this gateway
- m_query - Variable in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- m_query - Variable in class ca.uqac.lif.cep.jdbc.JdbcSource
-
The name of the database table to read from.
- m_queueLock - Variable in class ca.uqac.lif.cep.http.HttpDownstreamGateway
-
A lock to access the queue
- m_queues - Variable in class ca.uqac.lif.cep.hibernate.Hibernate
-
Each of the queues contained in the sink (one for each output pipe)
- m_random - Variable in class ca.uqac.lif.cep.signal.Noise
- m_range - Variable in class ca.uqac.lif.cep.complex.RangeCep
-
A push unit that evaluates the range processor.
- m_range - Variable in class ca.uqac.lif.cep.signal.Noise
- m_range - Variable in class ca.uqac.lif.cep.signal.PlateauFinder
-
The range all values should lie in
- m_reader - Variable in class ca.uqac.lif.cep.hibernate.FileHibernate
-
The reader that is used to read from the file
- m_receivedStrings - Variable in class ca.uqac.lif.cep.http.HttpDownstreamGateway
-
A queue of character strings received over the network
- m_refreshInterval - Variable in class ca.uqac.lif.cep.diagnostics.ThroughputMeter
- m_relation - Variable in class ca.uqac.lif.cep.fsm.MooreMachine
-
A map from a state to the list of transitions from that state
- m_relative - Variable in class ca.uqac.lif.cep.signal.PlateauFinder
-
Whether the height of the plateau should be relative to that of the last plateau (
true
), or absolute (false
) - m_responseCode - Variable in class ca.uqac.lif.cep.apache.HttpRequest
-
The response code sent
- m_resultSet - Variable in class ca.uqac.lif.cep.jdbc.JdbcSource
-
The query's result set, out of which tuples will be extracted one by one
- m_right - Variable in class ca.uqac.lif.cep.fol.LazyBooleanFunction
- m_run - Variable in class ca.uqac.lif.cep.diagnostics.Timer
- m_scanner - Variable in class ca.uqac.lif.cep.json.JsonLineFeeder
-
The scanner pulling lines from the input stream.
- m_separator - Variable in class ca.uqac.lif.cep.diagnostics.PrintThrough
-
The separator between each event
- m_separator - Variable in class ca.uqac.lif.cep.tuples.TupleFeeder
-
The character used to separate the text lines into fields
- m_serializer - Variable in class ca.uqac.lif.cep.serialization.DeserializeEvents
-
The serializer
- m_serializer - Variable in class ca.uqac.lif.cep.serialization.SerializeEvents
-
The serializer
- m_server - Variable in class ca.uqac.lif.cep.http.HttpDownstreamGateway
-
An internal instance of HTTP server
- m_server - Variable in class ca.uqac.lif.cep.http.HttpSource
-
An internal instance of HTTP server
- m_server - Variable in class ca.uqac.lif.cep.http.HttpUpstreamGateway
-
The web server that will listen for downstream pull requests
- m_sink - Variable in class ca.uqac.lif.cep.hibernate.Hibernate
-
A sink to receive the events produced by the processor
- m_size - Variable in class ca.uqac.lif.cep.apache.HttpRequest
-
The size of the response sent
- m_slowDown - Variable in class ca.uqac.lif.cep.diagnostics.Derivation
- m_sortAttributes - Variable in class ca.uqac.lif.cep.tuples.TupleComparator
-
The attributes over which to perform the comparison
- m_sourceIp - Variable in class ca.uqac.lif.cep.apache.HttpRequest
-
The source IP address
- m_statement - Variable in class ca.uqac.lif.cep.jdbc.JdbcSource
-
The statement object corresponding to the SQL query being executed
- m_stderrGobbler - Variable in class ca.uqac.lif.cep.provenance.CommandRunner
- m_stdin - Variable in class ca.uqac.lif.cep.provenance.CommandRunner
- m_stdoutGobbler - Variable in class ca.uqac.lif.cep.provenance.CommandRunner
- m_stop - Variable in class ca.uqac.lif.cep.provenance.CommandRunner
- m_stopValue - Variable in class ca.uqac.lif.cep.fol.LazyBooleanFunction
- m_stopValue - Variable in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- m_streamIndex - Variable in class ca.uqac.lif.cep.provenance.EventFunction
-
The index of the output stream on the processor
- m_streamIndex - Variable in class ca.uqac.lif.cep.provenance.IndexEventTracker.ProcessorConnection
- m_streamPosition - Variable in class ca.uqac.lif.cep.provenance.EventFunction
-
The position in the stream where the event is
- m_table - Variable in class ca.uqac.lif.cep.mtnp.UpdateTable
-
The table that is being updated by input events
- m_targetName - Variable in class ca.uqac.lif.cep.tuples.AttributeExpression
-
The attribute name to be given to this value
- m_textArea - Variable in class ca.uqac.lif.cep.diagnostics.WindowConsole
- m_threshold - Variable in class ca.uqac.lif.cep.signal.Threshold
-
The threshold to cut values
- m_timer - Variable in class ca.uqac.lif.cep.diagnostics.ThroughputMeter
- m_timeSinceLast - Variable in class ca.uqac.lif.cep.signal.Persist
- m_type - Variable in class ca.uqac.lif.cep.mtnp.DrawPlot
- m_type - Variable in class ca.uqac.lif.cep.mtnp.PrintGnuPlot
- m_unixTime - Variable in class ca.uqac.lif.cep.apache.HttpRequest
-
The time of the request: a Unix timestamp in seconds
- m_url - Variable in class ca.uqac.lif.cep.http.HttpDownstreamGateway
-
The URL on which the gateway listens for requests
- m_url - Variable in class ca.uqac.lif.cep.http.HttpSource
-
The URL on which the gateway listens for requests
- m_userId - Variable in class ca.uqac.lif.cep.apache.HttpRequest
-
User ID
- m_value - Variable in class ca.uqac.lif.cep.fol.PredicateTuple
-
The value associated to these arguments
- m_value - Variable in class ca.uqac.lif.cep.tuples.ProjectTuple.NameFunctionPair
- m_values - Variable in class ca.uqac.lif.cep.signal.WindowProcessor
-
The window of values to remember
- m_variable - Variable in class ca.uqac.lif.cep.fol.FirstOrderQuantifier
- m_variableName - Variable in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- m_width - Variable in class ca.uqac.lif.cep.signal.Persist
- m_width - Variable in class ca.uqac.lif.cep.signal.Smooth.ArrayAverage
-
The input arity of this function
- m_windowWidth - Variable in class ca.uqac.lif.cep.signal.WindowProcessor
-
The width of the window to process
- main(String[]) - Static method in class ca.uqac.lif.cep.apache.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.diagnostics.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.dsl.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.fol.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.fsm.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.http.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.io.websocket.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.jdbc.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.json.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.mtnp.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.provenance.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.serialization.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.signal.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.tuples.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.widgets.Main
- main(String[]) - Static method in class ca.uqac.lif.cep.widgets.TestFrame
- main(String[]) - Static method in class ca.uqac.lif.cep.xml.Main
- Main - Class in ca.uqac.lif.cep.apache
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.diagnostics
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.dsl
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.fol
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.fsm
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.http
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.io.websocket
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.jdbc
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.json
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.mtnp
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.provenance
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.serialization
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.signal
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.tuples
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.widgets
-
Dummy main file
- Main - Class in ca.uqac.lif.cep.xml
-
Dummy main file
- Main() - Constructor for class ca.uqac.lif.cep.apache.Main
- Main() - Constructor for class ca.uqac.lif.cep.diagnostics.Main
- Main() - Constructor for class ca.uqac.lif.cep.dsl.Main
- Main() - Constructor for class ca.uqac.lif.cep.fol.Main
- Main() - Constructor for class ca.uqac.lif.cep.fsm.Main
- Main() - Constructor for class ca.uqac.lif.cep.http.Main
- Main() - Constructor for class ca.uqac.lif.cep.io.websocket.Main
- Main() - Constructor for class ca.uqac.lif.cep.jdbc.Main
- Main() - Constructor for class ca.uqac.lif.cep.json.Main
- Main() - Constructor for class ca.uqac.lif.cep.mtnp.Main
- Main() - Constructor for class ca.uqac.lif.cep.provenance.Main
- Main() - Constructor for class ca.uqac.lif.cep.serialization.Main
- Main() - Constructor for class ca.uqac.lif.cep.signal.Main
- Main() - Constructor for class ca.uqac.lif.cep.tuples.Main
- Main() - Constructor for class ca.uqac.lif.cep.widgets.Main
- Main() - Constructor for class ca.uqac.lif.cep.xml.Main
- MapEntry(K, V) - Constructor for class ca.uqac.lif.cep.tuples.Tuple.MapEntry
- MapToTuple - Class in ca.uqac.lif.cep.tuples
-
Converts a
Map
object into aTuple
- matches(Predicate.PredicateArgument) - Method in class ca.uqac.lif.cep.fol.Predicate.PredicateArgument
- MergeScalars - Class in ca.uqac.lif.cep.tuples
-
Creates a named tuple out of multiple input traces, each containing scalar values.
- MergeScalars(String...) - Constructor for class ca.uqac.lif.cep.tuples.MergeScalars
- MergeScalars(List<String>) - Constructor for class ca.uqac.lif.cep.tuples.MergeScalars
- MergeTuples - Class in ca.uqac.lif.cep.tuples
-
Merges the key-value pairs of multiple tuples into a single tuple.
- MergeTuples() - Constructor for class ca.uqac.lif.cep.tuples.MergeTuples
- MergeTuples(int) - Constructor for class ca.uqac.lif.cep.tuples.MergeTuples
- methodToString(HttpRequest.Method) - Static method in class ca.uqac.lif.cep.apache.ParseCommonLog
-
Creates a string out of a method
- modifyContext(Object[], Object[], MooreMachine) - Method in class ca.uqac.lif.cep.fsm.FunctionTransition
- modifyContext(Object[], Object[], MooreMachine) - Method in class ca.uqac.lif.cep.fsm.MooreMachine.Transition
-
Modifies the context of the state machine
- MooreMachine - Class in ca.uqac.lif.cep.fsm
-
A finite-state automaton with output symbols associated to its states.
- MooreMachine(int, int) - Constructor for class ca.uqac.lif.cep.fsm.MooreMachine
- MooreMachine.Transition - Class in ca.uqac.lif.cep.fsm
-
Represents a transition in the Moore machine
- mouseClicked(MouseEvent) - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- MouseCoordinates - Class in ca.uqac.lif.cep.widgets
- mouseDragged(MouseEvent) - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- mouseEntered(MouseEvent) - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- mouseExited(MouseEvent) - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- mouseMoved(MouseEvent) - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- mousePressed(MouseEvent) - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- mouseReleased(MouseEvent) - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- MultilineGroupProcessorBuilder - Class in ca.uqac.lif.cep.dsl
- MultilineGroupProcessorBuilder() - Constructor for class ca.uqac.lif.cep.dsl.MultilineGroupProcessorBuilder
N
- NamedMapPlaceholder - Class in ca.uqac.lif.cep.tuples
- NamedMapPlaceholder(String) - Constructor for class ca.uqac.lif.cep.tuples.NamedMapPlaceholder
- NameFunctionPair(String, Function) - Constructor for class ca.uqac.lif.cep.tuples.ProjectTuple.NameFunctionPair
- newFork() - Method in class ca.uqac.lif.cep.dsl.GroupProcessorBuilder
- next() - Method in class ca.uqac.lif.cep.jdbc.BeepBeepResultSet
- Noise - Class in ca.uqac.lif.cep.signal
- Noise(float) - Constructor for class ca.uqac.lif.cep.signal.Noise
- notify(Object) - Method in class ca.uqac.lif.cep.diagnostics.DiagnosticsCallback
- notify(Object) - Method in class ca.uqac.lif.cep.diagnostics.ThroughputMeter.ThroughputCallback
- notify(Object) - Method in class ca.uqac.lif.cep.diagnostics.WindowConsole
- NumberValue - Class in ca.uqac.lif.cep.json
-
Extracts a number value from a JSON element.
- NumberValue() - Constructor for class ca.uqac.lif.cep.json.NumberValue
O
- onClose(int, String, boolean) - Method in class ca.uqac.lif.cep.io.websocket.WebSocketReader.WebSocketClientWrapper
- onError(Exception) - Method in class ca.uqac.lif.cep.io.websocket.WebSocketReader.WebSocketClientWrapper
- ONGOING - ca.uqac.lif.cep.complex.RangeCep.State
-
The event received is included within the range.
- onMessage(String) - Method in class ca.uqac.lif.cep.io.websocket.WebSocketReader.WebSocketClientWrapper
- onOpen(ServerHandshake) - Method in class ca.uqac.lif.cep.io.websocket.WebSocketReader.WebSocketClientWrapper
- Or(Function, Function) - Constructor for class ca.uqac.lif.cep.fol.LazyBooleanFunction.Or
- OutputValue(int, int, int) - Constructor for class ca.uqac.lif.cep.provenance.EventFunction.OutputValue
P
- ParseCommonLog - Class in ca.uqac.lif.cep.apache
-
Parses a line of an Apache log in the common log format and creates an
HttpRequest
object with it. - ParseException() - Constructor for exception ca.uqac.lif.cep.jdbc.Interpreter.ParseException
- parseExpression(String) - Static method in class ca.uqac.lif.cep.xml.XPathFunction
-
Parses an XPath expression from a string
- ParseJson - Class in ca.uqac.lif.cep.json
-
Function that converts a string into a JSON element
- parseParameters(String) - Static method in class ca.uqac.lif.cep.apache.ParseCommonLog
- parseTime(Calendar, String) - Static method in class ca.uqac.lif.cep.apache.ParseCommonLog
- ParseXml - Class in ca.uqac.lif.cep.xml
-
Function that converts a string into an XML element
- ParseXml() - Constructor for class ca.uqac.lif.cep.xml.ParseXml
- PassthroughCounter - Class in ca.uqac.lif.cep.diagnostics
-
A
Passthrough
processor that keeps the count of events that went through it. - PassthroughCounter() - Constructor for class ca.uqac.lif.cep.diagnostics.PassthroughCounter
-
Creates a new passthrough counter
- PeakFinderLocalMaximum - Class in ca.uqac.lif.cep.signal
-
Finds a peak in a data stream using the local maximum algorithm.
- PeakFinderLocalMaximum() - Constructor for class ca.uqac.lif.cep.signal.PeakFinderLocalMaximum
- PeakFinderLocalMaximum(int) - Constructor for class ca.uqac.lif.cep.signal.PeakFinderLocalMaximum
- PeakFinderTravelRise - Class in ca.uqac.lif.cep.signal
-
Finds peaks in a sequence of numerical values using the "travel-rise" technique.
- PeakFinderTravelRise(int) - Constructor for class ca.uqac.lif.cep.signal.PeakFinderTravelRise
- Persist - Class in ca.uqac.lif.cep.signal
-
Persists a locally maximal value for a certain amount of time.
- Persist(int) - Constructor for class ca.uqac.lif.cep.signal.Persist
-
Creates a new decay processor
- PlateauFinder - Class in ca.uqac.lif.cep.signal
-
Finds a plateau in a data stream.
- PlateauFinder() - Constructor for class ca.uqac.lif.cep.signal.PlateauFinder
-
Instantiates a plateau finder with default settings
- PlateauFinder(int) - Constructor for class ca.uqac.lif.cep.signal.PlateauFinder
-
Instantiates a plateau finder with default settings
- POST - ca.uqac.lif.cep.apache.HttpRequest.Method
- postProcess(Collection<XmlElement>) - Method in class ca.uqac.lif.cep.xml.XPathFunction
- postProcess(Collection<XmlElement>) - Method in class ca.uqac.lif.cep.xml.XPathFunctionGet
- postVisit(Deque<Object>) - Method in class ca.uqac.lif.cep.dsl.GroupProcessorBuilder
- postVisit(Deque<Object>) - Method in class ca.uqac.lif.cep.dsl.MultilineGroupProcessorBuilder
- Predicate - Class in ca.uqac.lif.cep.fol
- Predicate(Predicate) - Constructor for class ca.uqac.lif.cep.fol.Predicate
-
Creates a new predicate by copying its contents from another predicate
- Predicate(String, String...) - Constructor for class ca.uqac.lif.cep.fol.Predicate
-
Creates a new predicate
- Predicate.PredicateArgument - Class in ca.uqac.lif.cep.fol
- Predicate.Wildcard - Class in ca.uqac.lif.cep.fol
-
Special constant that can be used when evaluating a predicate to indicate a "don't care" value
- PredicateArgument(Object[]) - Constructor for class ca.uqac.lif.cep.fol.Predicate.PredicateArgument
-
Creates a new predicate argument with given values
- PredicateAssertion - Class in ca.uqac.lif.cep.fol
-
An assertion on the value of a predicate, to be evaluated on an
Interpretation
. - PredicateAssertion(String, Function...) - Constructor for class ca.uqac.lif.cep.fol.PredicateAssertion
-
Creates a new predicate assertion
- PredicateGet - Class in ca.uqac.lif.cep.fol
-
Extracts the value at a specific position in the predicate tuple.
- PredicateGet(int) - Constructor for class ca.uqac.lif.cep.fol.PredicateGet
-
Creates an instance of the function
- PredicateGetNumber - Class in ca.uqac.lif.cep.fol
-
Extracts the value at a specific position in the predicate tuple, and converts it into a number
- PredicateGetNumber(int) - Constructor for class ca.uqac.lif.cep.fol.PredicateGetNumber
- PredicateTuple - Class in ca.uqac.lif.cep.fol
-
An assertion defining the truth value of a predicate for a concrete list of arguments.
- PredicateTuple(String, boolean, Object[]) - Constructor for class ca.uqac.lif.cep.fol.PredicateTuple
-
Creates a new predicate tuple
- PredicateTupleConversion - Class in ca.uqac.lif.cep.fol
-
Unary function converting an object into a predicate tuple
- PredicateTupleReader - Class in ca.uqac.lif.cep.fol
-
Processor receiving objects as input and outputting predicate tuples as its output
- PredicateTupleReader() - Constructor for class ca.uqac.lif.cep.fol.PredicateTupleReader
- prepareStatement(String) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepConnection
- PrintGnuPlot - Class in ca.uqac.lif.cep.mtnp
-
Generates a GnuPlot file drawing a plot from a
Table
object. - PrintGnuPlot() - Constructor for class ca.uqac.lif.cep.mtnp.PrintGnuPlot
- PrintGnuPlot(GnuPlot) - Constructor for class ca.uqac.lif.cep.mtnp.PrintGnuPlot
- PrintGnuPlot(GnuPlot, Plot.ImageType) - Constructor for class ca.uqac.lif.cep.mtnp.PrintGnuPlot
- PrintThrough - Class in ca.uqac.lif.cep.diagnostics
-
A
Passthrough
processor that prints every event it receives to the standard output. - PrintThrough() - Constructor for class ca.uqac.lif.cep.diagnostics.PrintThrough
- printTree(ProvenanceNode, PrintStream) - Static method in class ca.uqac.lif.cep.provenance.ProvenanceTree
- printTree(ProvenanceNode, PrintStream, String) - Static method in class ca.uqac.lif.cep.provenance.ProvenanceTree
- process(HttpExchange) - Method in class ca.uqac.lif.cep.http.HttpDownstreamGateway.ListenerCallback
- process(HttpExchange) - Method in class ca.uqac.lif.cep.http.HttpSource.ListenerCallback
- process(HttpExchange) - Method in class ca.uqac.lif.cep.http.HttpUpstreamGateway.PullCallback
- ProcessorConnection(int, int) - Constructor for class ca.uqac.lif.cep.provenance.IndexEventTracker.ProcessorConnection
- ProcessorTransition - Class in ca.uqac.lif.cep.fsm
-
Represents a transition in the Moore machine.
- ProcessorTransition(int, Processor) - Constructor for class ca.uqac.lif.cep.fsm.ProcessorTransition
-
Instantiates a new transition
- ProcessorTransition(ProcessorTransition) - Constructor for class ca.uqac.lif.cep.fsm.ProcessorTransition
-
Creates a new processor transition from another transition.
- ProcessorTransition(ProcessorTransition, boolean) - Constructor for class ca.uqac.lif.cep.fsm.ProcessorTransition
-
Creates a new processor transition, by copying state from another transition.
- produceComplexEvent() - Method in class ca.uqac.lif.cep.complex.RangeCep
-
Produces the complex output event out of the last event output by each data processor.
- ProjectTuple - Class in ca.uqac.lif.cep.tuples
-
Creates an output tuple from input tuples by combining their values.
- ProjectTuple(int, ProjectTuple.NameFunctionPair...) - Constructor for class ca.uqac.lif.cep.tuples.ProjectTuple
-
Creates a new instance of the function
- ProjectTuple(ProjectTuple.NameFunctionPair...) - Constructor for class ca.uqac.lif.cep.tuples.ProjectTuple
-
Creates a new instance of the function
- ProjectTuple.NameFunctionPair - Class in ca.uqac.lif.cep.tuples
-
Associates a tuple's key to a function to be evaluated on input tuples
- ProvenanceTree - Class in ca.uqac.lif.cep.provenance
- ProvenanceTree() - Constructor for class ca.uqac.lif.cep.provenance.ProvenanceTree
- PullCallback() - Constructor for class ca.uqac.lif.cep.http.HttpUpstreamGateway.PullCallback
- pushFront(Object[]) - Method in class ca.uqac.lif.cep.complex.RangeCep
-
Pushes an event front to all data processors.
- put(String, Object) - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- put(String, Object) - Method in class ca.uqac.lif.cep.tuples.TupleMap
- put(String, T) - Method in class ca.uqac.lif.cep.tuples.CacheMap
- PUT - ca.uqac.lif.cep.apache.HttpRequest.Method
- putAll(Map<? extends String, ? extends Object>) - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- putAll(Map<? extends String, ? extends Object>) - Method in class ca.uqac.lif.cep.tuples.TupleMap
- putAll(Map<? extends String, ? extends T>) - Method in class ca.uqac.lif.cep.tuples.CacheMap
- putAll(T[]) - Method in class ca.uqac.lif.cep.tuples.CacheMap
- putAt(int, T) - Method in class ca.uqac.lif.cep.tuples.CacheMap
Q
- QuantifierInterpretation - Class in ca.uqac.lif.cep.fol
- QuantifierInterpretation(String, String, Function, boolean) - Constructor for class ca.uqac.lif.cep.fol.QuantifierInterpretation
- queryToMap(String, HttpRequest.Method) - Static method in class ca.uqac.lif.cep.apache.ParseCommonLog
-
Convenience method to transform a GET query into a map of attribute-value pairs.
R
- RangeCep - Class in ca.uqac.lif.cep.complex
-
Creates complex events out of a range of simple events.
- RangeCep(Processor, Processor[], Function) - Constructor for class ca.uqac.lif.cep.complex.RangeCep
-
Creates a new range complex event processor.
- RangeCep(PushUnit, PushUnit[], Function) - Constructor for class ca.uqac.lif.cep.complex.RangeCep
-
Creates a new range complex event processor.
- RangeCep.State - Enum in ca.uqac.lif.cep.complex
-
The current state of the range, which is updated upon receiving each input event.
- reconnect(Processor, int, Processor, int) - Method in class ca.uqac.lif.cep.diagnostics.Derivation
-
Reconnects p1 and p2 so as to place the current processor in-between.
- reconnect(Processor, Processor) - Method in class ca.uqac.lif.cep.diagnostics.Derivation
-
Reconnects p1 and p2 so as to place the current processor in-between.
- RegexAttributeNameList() - Constructor for class ca.uqac.lif.cep.tuples.RegexTupleBuilder.RegexAttributeNameList
- RegexTupleBuilder - Class in ca.uqac.lif.cep.tuples
-
Builds a tuple out of parts of text.
- RegexTupleBuilder(String, RegexTupleBuilder.RegexAttributeNameList) - Constructor for class ca.uqac.lif.cep.tuples.RegexTupleBuilder
-
Constructs a tuple builder.
- RegexTupleBuilder.RegexAttributeNameList - Class in ca.uqac.lif.cep.tuples
- remove(Processor...) - Method in class ca.uqac.lif.cep.dsl.GroupProcessorBuilder
- remove(Object) - Method in class ca.uqac.lif.cep.tuples.CacheMap
- remove(Object) - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- remove(Object) - Method in class ca.uqac.lif.cep.tuples.TupleMap
- reset() - Method in class ca.uqac.lif.cep.complex.RangeCep
- reset() - Method in class ca.uqac.lif.cep.diagnostics.PassthroughCounter
- reset() - Method in class ca.uqac.lif.cep.fol.InterpretationBuilder
- reset() - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction
- reset() - Method in class ca.uqac.lif.cep.fol.Predicate
- reset() - Method in class ca.uqac.lif.cep.fol.PredicateAssertion
- reset() - Method in class ca.uqac.lif.cep.fol.QuantifierInterpretation
- reset() - Method in class ca.uqac.lif.cep.fsm.MooreMachine
- reset() - Method in class ca.uqac.lif.cep.fsm.MooreMachine.Transition
-
Resets the state of the transition
- reset() - Method in class ca.uqac.lif.cep.fsm.ProcessorTransition
- reset() - Method in class ca.uqac.lif.cep.http.HttpSource
- reset() - Method in interface ca.uqac.lif.cep.jdbc.Interpreter
-
Resets the state of the interpreter
- reset() - Method in class ca.uqac.lif.cep.jdbc.JdbcSource
- reset() - Method in class ca.uqac.lif.cep.mtnp.UpdateTable
- reset() - Method in class ca.uqac.lif.cep.serialization.DeserializeEvents
- reset() - Method in class ca.uqac.lif.cep.serialization.SerializeEvents
- reset() - Method in class ca.uqac.lif.cep.signal.PeakFinderLocalMaximum
- reset() - Method in class ca.uqac.lif.cep.signal.Persist
- reset() - Method in class ca.uqac.lif.cep.signal.PlateauFinder
- reset() - Method in class ca.uqac.lif.cep.signal.Smooth.ArrayAverage
- reset() - Method in class ca.uqac.lif.cep.signal.WindowProcessor
- reset() - Method in class ca.uqac.lif.cep.tuples.FromFunction
- reset() - Method in class ca.uqac.lif.cep.tuples.MergeScalars
- reset() - Method in class ca.uqac.lif.cep.tuples.MergeTuples
- reset() - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- run() - Method in class ca.uqac.lif.cep.diagnostics.Timer
- run() - Method in class ca.uqac.lif.cep.provenance.CommandRunner
- run() - Method in class ca.uqac.lif.cep.provenance.CommandRunner.StreamGobbler
- runAndGet(String[], String) - Static method in class ca.uqac.lif.cep.provenance.CommandRunner
- runAndGet(String, String) - Static method in class ca.uqac.lif.cep.provenance.CommandRunner
S
- s_dependencyFunction - Static variable in class ca.uqac.lif.cep.provenance.EventFunction
-
An instance of the
DirectValue
node function. - s_k - Static variable in class ca.uqac.lif.cep.signal.PeakFinderTravelRise
- s_linePattern - Static variable in class ca.uqac.lif.cep.apache.ParseCommonLog
-
The pattern to parse a line of the log
- s_numRetries - Static variable in class ca.uqac.lif.cep.http.HttpUpstreamGateway
-
The number of times the processor will retry when it fails to establish a connection to the other end
- s_parser - Static variable in class ca.uqac.lif.cep.json.JsonLineFeeder
-
The parser used to parse the elements.
- s_parser - Static variable in class ca.uqac.lif.cep.json.ParseJson
-
The parser used to parse the elements.
- s_precision - Static variable in class ca.uqac.lif.cep.signal.WindowProcessor
-
The precision used to for the equality between double precision numbers
- s_prefix - Static variable in class ca.uqac.lif.cep.jdbc.BeepBeepDriver
- s_urlPattern - Static variable in class ca.uqac.lif.cep.apache.ParseCommonLog
-
The pattern to parse a URL
- s_userAgent - Static variable in class ca.uqac.lif.cep.http.HttpGateway
- ScalarIntoTuple - Class in ca.uqac.lif.cep.tuples
-
Turns a scalar object into a singleton tuple.
- ScalarIntoTuple(String) - Constructor for class ca.uqac.lif.cep.tuples.ScalarIntoTuple
-
Creates a new instance of the function
- Select - Class in ca.uqac.lif.cep.tuples
-
Creates a Tuple from an
AttributeGroup
. - Select(AttributeExpression...) - Constructor for class ca.uqac.lif.cep.tuples.Select
- Select(Select.SelectFunction) - Constructor for class ca.uqac.lif.cep.tuples.Select
- Select(Collection<AttributeExpression>) - Constructor for class ca.uqac.lif.cep.tuples.Select
- Select.SelectFunction - Class in ca.uqac.lif.cep.tuples
-
The internal function performing the actual work for the
From
processor. - SelectFunction(AttributeExpression...) - Constructor for class ca.uqac.lif.cep.tuples.Select.SelectFunction
-
Creates a new instance of the
SELECT
function - SelectFunction(Collection<AttributeExpression>) - Constructor for class ca.uqac.lif.cep.tuples.Select.SelectFunction
-
Creates a new instance of the
SELECT
function - sendGet(String) - Static method in class ca.uqac.lif.cep.http.HttpGateway
-
Sends a GET request to a specified URL
- sendPost(String, String) - Static method in class ca.uqac.lif.cep.http.HttpGateway
-
Sends a POST request to a specified URL
- SerializeEvents<T> - Class in ca.uqac.lif.cep.serialization
-
Function that applies a serializer to its input argument.
- SerializeEvents(ObjectPrinter<T>, Class<T>) - Constructor for class ca.uqac.lif.cep.serialization.SerializeEvents
-
Creates a new instance of the function.
- setArray(int, Array) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setAsciiStream(int, InputStream) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setAsciiStream(int, InputStream, int) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setAsciiStream(int, InputStream, long) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setBigDecimal(int, BigDecimal) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setBinaryStream(int, InputStream) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setBinaryStream(int, InputStream, int) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setBinaryStream(int, InputStream, long) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setBlob(int, InputStream) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setBlob(int, InputStream, long) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setBlob(int, Blob) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setBoolean(int, boolean) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setByte(int, byte) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setBytes(int, byte[]) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setCallback(DiagnosticsCallback, int) - Method in class ca.uqac.lif.cep.diagnostics.PassthroughCounter
- setCharacterStream(int, Reader) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setCharacterStream(int, Reader, int) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setCharacterStream(int, Reader, long) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setClob(int, Reader) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setClob(int, Reader, long) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setClob(int, Clob) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setCommentChar(String) - Method in class ca.uqac.lif.cep.dsl.MultilineGroupProcessorBuilder
-
Sets the character used to mark comment lines
- setCondition(Function) - Method in class ca.uqac.lif.cep.tuples.Where
- setConnection(int, int, int, int) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
- setConnection(Map<Integer, Map<Integer, IndexEventTracker.ProcessorConnection>>, int, int, IndexEventTracker.ProcessorConnection) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
- setContext(Context) - Method in class ca.uqac.lif.cep.hibernate.Hibernate
- setContext(String, Object) - Method in class ca.uqac.lif.cep.hibernate.Hibernate
- setDate(int, Date) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setDate(int, Date, Calendar) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setDouble(int, double) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setFailFast(boolean) - Method in class ca.uqac.lif.cep.fol.QuantifierInterpretation
-
Sets whether the quantifier evaluates the functions in "fail fast" mode
- setFeedOneByOne(boolean) - Method in class ca.uqac.lif.cep.jdbc.JdbcSource
-
Sets whether the tuples of the underlying relation should be output one by one on every call to
JdbcSource.compute(Object[], Queue)
, or output all at once on the first call to that method. - setFloat(int, float) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setGrammar(InputStream) - Method in class ca.uqac.lif.cep.dsl.GrammarObjectBuilder
- setGrammar(String) - Method in class ca.uqac.lif.cep.dsl.GrammarObjectBuilder
- setImageType(Plot.ImageType) - Method in class ca.uqac.lif.cep.mtnp.DrawPlot
- setImageType(Plot.ImageType) - Method in class ca.uqac.lif.cep.mtnp.PrintGnuPlot
- setInt(int, int) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setLong(int, long) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setNCharacterStream(int, Reader) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setNCharacterStream(int, Reader, long) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setNClob(int, Reader) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setNClob(int, Reader, long) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setNClob(int, NClob) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setNString(int, String) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setNull(int, int) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setNull(int, int, String) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setObject(int, Object) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setObject(int, Object, int) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setObject(int, Object, int, int) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setPlateauRange(int) - Method in class ca.uqac.lif.cep.signal.PlateauFinder
-
Sets the range all values should lie in to be considered in the same plateau
- setPlot(GnuPlot) - Method in class ca.uqac.lif.cep.mtnp.PrintGnuPlot
- setPlot(Plot) - Method in class ca.uqac.lif.cep.mtnp.DrawPlot
- setPullMethod(RequestCallback.Method) - Method in class ca.uqac.lif.cep.http.HttpUpstreamGateway
-
Sets the method (GET or POST) the gateway will respond to when listening to pull requests from downstream
- setPushOnReceive(boolean) - Method in class ca.uqac.lif.cep.http.HttpDownstreamGateway
- setRef(int, Ref) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setRelative(boolean) - Method in class ca.uqac.lif.cep.signal.PlateauFinder
-
Sets whether the height of the plateau should be relative to that of the last plateau (
true
), or absolute (false
) - setRowId(int, RowId) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setSeparator(String) - Method in class ca.uqac.lif.cep.tuples.TupleFeeder
-
Sets the character used to separate the text lines into fields
- setShort(int, short) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setSQLXML(int, SQLXML) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setString(int, String) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setTime(int, Time) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setTime(int, Time, Calendar) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setTimestamp(int, Timestamp) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setTimestamp(int, Timestamp, Calendar) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setTo(Processor...) - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker
- setUnicodeStream(int, InputStream, int) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setURL(int, URL) - Method in class ca.uqac.lif.cep.jdbc.BeepBeepPreparedStatement
- setValue(V) - Method in class ca.uqac.lif.cep.tuples.Tuple.MapEntry
- size() - Method in class ca.uqac.lif.cep.fol.Predicate.PredicateArgument
- size() - Method in class ca.uqac.lif.cep.tuples.CacheMap
- size() - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- size() - Method in class ca.uqac.lif.cep.tuples.TupleMap
- Smooth - Class in ca.uqac.lif.cep.signal
- Smooth(int) - Constructor for class ca.uqac.lif.cep.signal.Smooth
- Smooth.ArrayAverage - Class in ca.uqac.lif.cep.signal
-
Computes the average of values in an array
- SpliceJsonStreamSource - Class in ca.uqac.lif.cep.json
-
A splice source that reads a JSONStream document and produces a stream of JSON elements.
- SpliceJsonStreamSource(boolean, String...) - Constructor for class ca.uqac.lif.cep.json.SpliceJsonStreamSource
- SpliceTupleSource - Class in ca.uqac.lif.cep.tuples
-
A splice source that generates a stream of tuples.
- SpliceTupleSource(boolean, String...) - Constructor for class ca.uqac.lif.cep.tuples.SpliceTupleSource
- start() - Method in class ca.uqac.lif.cep.diagnostics.Derivation
- start() - Method in class ca.uqac.lif.cep.diagnostics.ThroughputMeter
- start() - Method in class ca.uqac.lif.cep.http.HttpDownstreamGateway
- start() - Method in class ca.uqac.lif.cep.http.HttpSource
- start() - Method in class ca.uqac.lif.cep.http.HttpUpstreamGateway
- stateChanged(ChangeEvent) - Method in class ca.uqac.lif.cep.widgets.ListenerSource
- stop() - Method in class ca.uqac.lif.cep.diagnostics.Derivation
- stop() - Method in class ca.uqac.lif.cep.diagnostics.ThroughputMeter
- stop() - Method in class ca.uqac.lif.cep.diagnostics.Timer
- stop() - Method in class ca.uqac.lif.cep.http.HttpDownstreamGateway
- stop() - Method in class ca.uqac.lif.cep.http.HttpSource
- stop() - Method in class ca.uqac.lif.cep.http.HttpUpstreamGateway
- stop() - Method in class ca.uqac.lif.cep.json.JsonLineFeeder
- stopCommand() - Method in class ca.uqac.lif.cep.provenance.CommandRunner
-
Interrupts the execution of the command
- stringToMethod(String) - Static method in class ca.uqac.lif.cep.apache.ParseCommonLog
- stringToMonth(String) - Static method in class ca.uqac.lif.cep.apache.ParseCommonLog
- StringValue - Class in ca.uqac.lif.cep.json
-
Extracts a number value from a JSON element.
- StringValue() - Constructor for class ca.uqac.lif.cep.json.StringValue
- styleNode(ProvenanceNode) - Method in class ca.uqac.lif.cep.provenance.DotProvenanceTreeRenderer
T
- TestFrame - Class in ca.uqac.lif.cep.widgets
- TestFrame() - Constructor for class ca.uqac.lif.cep.widgets.TestFrame
- Threshold - Class in ca.uqac.lif.cep.signal
- Threshold(float) - Constructor for class ca.uqac.lif.cep.signal.Threshold
- ThroughputCallback() - Constructor for class ca.uqac.lif.cep.diagnostics.ThroughputMeter.ThroughputCallback
- ThroughputMeter - Class in ca.uqac.lif.cep.diagnostics
- ThroughputMeter(DiagnosticsCallback, long) - Constructor for class ca.uqac.lif.cep.diagnostics.ThroughputMeter
- ThroughputMeter.ThroughputCallback - Class in ca.uqac.lif.cep.diagnostics
- Timer - Class in ca.uqac.lif.cep.diagnostics
-
Timer that pushes the contents of
m_packedEvents
everym_outputInterval
milliseconds. - Timer(DiagnosticsCallback, long) - Constructor for class ca.uqac.lif.cep.diagnostics.Timer
- toDot(ProvenanceNode...) - Method in class ca.uqac.lif.cep.provenance.DotProvenanceTreeRenderer
- toDot(ProvenanceNode, String, int, StringBuilder) - Method in class ca.uqac.lif.cep.provenance.DotProvenanceTreeRenderer
- ToImageIcon - Class in ca.uqac.lif.cep.widgets
- ToImageIcon() - Constructor for class ca.uqac.lif.cep.widgets.ToImageIcon
- toPredicateTuple(Object) - Static method in class ca.uqac.lif.cep.fol.PredicateTuple
-
Creates a predicate tuple out of an object.
- toString() - Method in class ca.uqac.lif.cep.apache.HttpRequest
- toString() - Method in class ca.uqac.lif.cep.fol.ExistsInterpretation
- toString() - Method in class ca.uqac.lif.cep.fol.ForAllInterpretation
- toString() - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction.And
- toString() - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction.Implies
- toString() - Method in class ca.uqac.lif.cep.fol.LazyBooleanFunction.Or
- toString() - Method in class ca.uqac.lif.cep.fol.Predicate.PredicateArgument
- toString() - Method in class ca.uqac.lif.cep.fol.Predicate
- toString() - Method in class ca.uqac.lif.cep.fol.PredicateAssertion
- toString() - Method in class ca.uqac.lif.cep.fol.PredicateTuple
- toString() - Method in class ca.uqac.lif.cep.fsm.FunctionTransition
- toString() - Method in class ca.uqac.lif.cep.fsm.ProcessorTransition
- toString() - Method in class ca.uqac.lif.cep.fsm.TransitionOtherwise
- toString() - Method in class ca.uqac.lif.cep.provenance.EventFunction
- toString() - Method in class ca.uqac.lif.cep.provenance.IndexEventTracker.ProcessorConnection
- toString() - Method in class ca.uqac.lif.cep.tuples.AttributeExpression
- toString() - Method in class ca.uqac.lif.cep.tuples.AttributeGroup
- toString() - Method in class ca.uqac.lif.cep.tuples.CacheMap
- toString() - Method in class ca.uqac.lif.cep.tuples.FetchAttribute
- toString() - Method in class ca.uqac.lif.cep.tuples.From
- toString() - Method in class ca.uqac.lif.cep.tuples.GetAttribute
- toString() - Method in class ca.uqac.lif.cep.tuples.Select
- toString() - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- toString() - Method in class ca.uqac.lif.cep.tuples.TupleMap
- toString() - Method in class ca.uqac.lif.cep.xml.XPathFunction
- Transition() - Constructor for class ca.uqac.lif.cep.fsm.MooreMachine.Transition
-
Creates a new transition
- Transition(MooreMachine.Transition) - Constructor for class ca.uqac.lif.cep.fsm.MooreMachine.Transition
-
Copies a transition from another transition
- TransitionOtherwise - Class in ca.uqac.lif.cep.fsm
-
Represents the "otherwise" transition in the Moore machine
- TransitionOtherwise(int) - Constructor for class ca.uqac.lif.cep.fsm.TransitionOtherwise
- TransitionOtherwise(int, ContextAssignment) - Constructor for class ca.uqac.lif.cep.fsm.TransitionOtherwise
- TransitionOtherwise(int, ContextAssignment...) - Constructor for class ca.uqac.lif.cep.fsm.TransitionOtherwise
- TransitionOtherwise(TransitionOtherwise) - Constructor for class ca.uqac.lif.cep.fsm.TransitionOtherwise
- TransposePair - Class in ca.uqac.lif.cep.tuples
-
Creates two Applies a triple substitution to a singleton tuple.
- TransposePair(String, String) - Constructor for class ca.uqac.lif.cep.tuples.TransposePair
-
Creates a new instance of the tuple transposition function.
- Tuple - Class in ca.uqac.lif.cep.tuples
-
A (named) tuple is a map between attribute names (character strings) and attribute values (any kind of Object).
- Tuple() - Constructor for class ca.uqac.lif.cep.tuples.Tuple
- Tuple.MapEntry<K,V> - Class in ca.uqac.lif.cep.tuples
-
Simple implementation of the Map interface
- TupleComparator - Class in ca.uqac.lif.cep.tuples
-
Compares two tuples according to the values of one or many of their attributes.
- TupleComparator(String...) - Constructor for class ca.uqac.lif.cep.tuples.TupleComparator
-
Creates a new tuple comparator
- TupleFeeder - Class in ca.uqac.lif.cep.tuples
-
Creates a feed of events from CRLF-separated string chunks.
- TupleFeeder() - Constructor for class ca.uqac.lif.cep.tuples.TupleFeeder
-
Create a new tuple feeder
- TupleFeeder(FixedTupleBuilder) - Constructor for class ca.uqac.lif.cep.tuples.TupleFeeder
-
Create a new tuple feeder using a predefined tuple builder
- TupleFixed - Class in ca.uqac.lif.cep.tuples
-
Implementation of a named tuple.
- TupleFixed(String[], Object[]) - Constructor for class ca.uqac.lif.cep.tuples.TupleFixed
- TupleMap - Class in ca.uqac.lif.cep.tuples
-
Implementation of a named tuple based on the
Map
class. - TupleMap() - Constructor for class ca.uqac.lif.cep.tuples.TupleMap
-
Creates a new named tple
- TupleMap(TupleMap) - Constructor for class ca.uqac.lif.cep.tuples.TupleMap
-
Creates a new named tuple by copying the contents of an existing named tuple
- TupleMap(String[], Object[]) - Constructor for class ca.uqac.lif.cep.tuples.TupleMap
U
- updateDefinition(PredicateTuple) - Method in class ca.uqac.lif.cep.fol.Predicate
- updateDefinition(Object[], boolean) - Method in class ca.uqac.lif.cep.fol.Predicate
- updatePathHistory() - Method in class ca.uqac.lif.cep.fsm.MooreMachine
- updateProvenance() - Method in class ca.uqac.lif.cep.fsm.MooreMachine
- UpdateTable - Class in ca.uqac.lif.cep.mtnp
-
Adds contents to a table based on incoming events.
- UpdateTable(int, HardTable) - Constructor for class ca.uqac.lif.cep.mtnp.UpdateTable
-
Creates a new instance of the processor.
- UpdateTable(int, String...) - Constructor for class ca.uqac.lif.cep.mtnp.UpdateTable
-
Creates a new instance of the processor.
- UpdateTable(int, List<String>) - Constructor for class ca.uqac.lif.cep.mtnp.UpdateTable
-
Creates a new instance of the processor.
- UpdateTableArray - Class in ca.uqac.lif.cep.mtnp
-
Adds contents to a table from a stream of arrays.
- UpdateTableArray(HardTable) - Constructor for class ca.uqac.lif.cep.mtnp.UpdateTableArray
-
Creates a new instance of the processor.
- UpdateTableArray(String...) - Constructor for class ca.uqac.lif.cep.mtnp.UpdateTableArray
-
Creates a new instance of the processor.
- UpdateTableArray(List<String>) - Constructor for class ca.uqac.lif.cep.mtnp.UpdateTableArray
-
Creates a new instance of the processor.
- UpdateTableMap - Class in ca.uqac.lif.cep.mtnp
-
Adds contents to a table by receiving a stream of
Map
objects, each corresponding to a tuple of key-value pairs to add to the table. - UpdateTableMap(String...) - Constructor for class ca.uqac.lif.cep.mtnp.UpdateTableMap
- UpdateTableMap(List<String>) - Constructor for class ca.uqac.lif.cep.mtnp.UpdateTableMap
- UpdateTableStream - Class in ca.uqac.lif.cep.mtnp
-
Adds contents to a table from multiple streams.
- UpdateTableStream(HardTable, String...) - Constructor for class ca.uqac.lif.cep.mtnp.UpdateTableStream
-
Creates a new instance of the processor.
- UpdateTableStream(String...) - Constructor for class ca.uqac.lif.cep.mtnp.UpdateTableStream
-
Creates a new instance of the processor.
- UpdateTableStream(List<String>) - Constructor for class ca.uqac.lif.cep.mtnp.UpdateTableStream
-
Creates a new instance of the processor.
V
- valueOf(String) - Static method in enum ca.uqac.lif.cep.apache.HttpRequest.Method
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum ca.uqac.lif.cep.complex.RangeCep.State
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum ca.uqac.lif.cep.apache.HttpRequest.Method
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum ca.uqac.lif.cep.complex.RangeCep.State
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Method in class ca.uqac.lif.cep.tuples.CacheMap
- values() - Method in class ca.uqac.lif.cep.tuples.TupleFixed
- values() - Method in class ca.uqac.lif.cep.tuples.TupleMap
W
- WebSocketClientWrapper(URI) - Constructor for class ca.uqac.lif.cep.io.websocket.WebSocketReader.WebSocketClientWrapper
- WebSocketReader - Class in ca.uqac.lif.cep.io.websocket
-
Reads chunks of data from a websocket.
- WebSocketReader(URI) - Constructor for class ca.uqac.lif.cep.io.websocket.WebSocketReader
-
Creates a new web socket reader
- WebSocketReader.WebSocketClientWrapper - Class in ca.uqac.lif.cep.io.websocket
-
A wrapper class so that this processor can be used as an instance of
WebSocketClient
- Where - Class in ca.uqac.lif.cep.tuples
-
Filters a trace of
AttributeGroup
objects according to a Boolean function - Where(Function) - Constructor for class ca.uqac.lif.cep.tuples.Where
- WidgetSink - Class in ca.uqac.lif.cep.widgets
- WidgetSink(Component) - Constructor for class ca.uqac.lif.cep.widgets.WidgetSink
- WidgetSink(Component, int) - Constructor for class ca.uqac.lif.cep.widgets.WidgetSink
- WindowConsole - Class in ca.uqac.lif.cep.diagnostics
-
Prints whatever is given to it in a text window.
- WindowConsole(String) - Constructor for class ca.uqac.lif.cep.diagnostics.WindowConsole
- WindowProcessor - Class in ca.uqac.lif.cep.signal
- WindowProcessor() - Constructor for class ca.uqac.lif.cep.signal.WindowProcessor
- WindowProcessor(int) - Constructor for class ca.uqac.lif.cep.signal.WindowProcessor
X
- XPathFunction - Class in ca.uqac.lif.cep.xml
-
Function that converts a string into an XML element
- XPathFunction(XPathExpression) - Constructor for class ca.uqac.lif.cep.xml.XPathFunction
-
Creates a new XPath function
- XPathFunction(String) - Constructor for class ca.uqac.lif.cep.xml.XPathFunction
- XPathFunctionGet<T> - Class in ca.uqac.lif.cep.xml
-
Utility function to evaluate an XPath expression, ending with a
text()
element - XPathFunctionGet(XPathExpression, Class<T>) - Constructor for class ca.uqac.lif.cep.xml.XPathFunctionGet
- XPathFunctionGet(String, Class<T>) - Constructor for class ca.uqac.lif.cep.xml.XPathFunctionGet
- XPathFunctionGetNumber - Class in ca.uqac.lif.cep.xml
-
Utility function to evaluate an XPath expression, ending with a
text()
element - XPathFunctionGetNumber(XPathExpression) - Constructor for class ca.uqac.lif.cep.xml.XPathFunctionGetNumber
- XPathFunctionGetNumber(String) - Constructor for class ca.uqac.lif.cep.xml.XPathFunctionGetNumber
- XPathFunctionGetText - Class in ca.uqac.lif.cep.xml
-
Utility function to evaluate an XPath expression, ending with a
text()
element - XPathFunctionGetText(XPathExpression) - Constructor for class ca.uqac.lif.cep.xml.XPathFunctionGetText
- XPathFunctionGetText(String) - Constructor for class ca.uqac.lif.cep.xml.XPathFunctionGetText
All Classes All Packages