Object -
streams :
OperandProcessor
Processor to perform operand processor operations.
Constructor
__init
(string alias, function(map) returns (boolean)
onConditionFunc, int minOccurs, int maxOccurs)
Methods
Processes the StreamEvent
.
Set the StateMachine
to the procesor and it's descendants.
Removes a given StreamEvent
from the StateMachine
.
Validates the processor and its configs.
Sets a link to the previous AbstractOperatorProcessor
.
Returns the alias of the current processor.
Fields
- alias string
-
processor alias
- minOccurs int 1
-
minimum occurrences of the event
- maxOccurs int 1
-
maximum occurrences of the event
- checkRange boolean false
-
is counting pattern
- lastEvent StreamEvent?
-
if there's counting patterns,
lastEvent
will accumulate event data.
Processes the StreamEvent
.
Parameters
- event StreamEvent
-
event to process
- processorAlias string?
-
alias for the calling processor, for identification purposes (lhs, rhs).
Set the StateMachine
to the procesor and it's descendants.
Parameters
- stateMachine StateMachine
-
StateMachine
instance
Removes a given StreamEvent
from the StateMachine
.
Parameters
- streamEvent StreamEvent
-
event to be removed
Sets a link to the previous AbstractOperatorProcessor
.
Parameters
- processor AbstractOperatorProcessor
-
previous processor