Object -
streams
:
OperandProcessor
Processor to perform operand processor operations.
Constructor
__init
(string alias, function(map) returns (boolean)
onConditionFunc, int minOccurs, int maxOccurs)
- alias string
- onConditionFunc
function(map) returns (boolean)
- minOccurs int
- maxOccurs int
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
- onConditionFunc
function(map) returns (boolean)
-
condition function (i.e [e1.id == id])
- 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).
-
Return Type
([boolean, boolean]) a tuple indicating, whether the event is promoted and whether to continue to the next processor.
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