Object -
streams
:
OrOperatorProcessor
Processor to perform OR stream operations.
Methods
Processes the StreamEvent
.
Set the StateMachine
to the procesor and it's descendants.
Validates the processor and its configs.
Promotes the StreamEvent
to the previous processor.
Evicts the StreamEvent
from current state branch.
Removes a given StreamEvent
from the StateMachine
.
Sets a link to the previous AbstractOperatorProcessor
.
Sets a link to the lhs AbstractOperatorProcessor
.
Sets a link to the rhs AbstractOperatorProcessor
.
Returns the alias of the current processor.
Fields
- lhsProcessor AbstractPatternProcessor?
-
LHS processor of the AND processor
- rhsProcessor AbstractPatternProcessor?
-
RHS processor of the AND processor
- lhsEvicted map
-
LHS partially evicted states
- rhsEvicted map
-
RHS partially evicted states
- lhsAlias string lhs
-
LHS processor alias
- rhsAlias string rhs
-
RHS processor alias
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
Promotes the StreamEvent
to the previous processor.
Parameters
- stateEvent StreamEvent
-
event to promote
- processorAlias string
-
alias for the calling processor, for identification purposes (lhs, rhs).
Evicts the StreamEvent
from current state branch.
Parameters
- stateEvent StreamEvent
-
event to promote
- processorAlias string
-
alias for the calling processor, for identification purposes (lhs, rhs).
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
Sets a link to the lhs AbstractOperatorProcessor
.
Parameters
- processor AbstractPatternProcessor
-
lhs processor
Sets a link to the rhs AbstractOperatorProcessor
.
Parameters
- processor AbstractPatternProcessor
-
rhs processor