Object -
streams
:
Max
Aggregator to find the maximum value in a stream.
Methods
Updates the current maximum value and return the updated maximum value.
Returns a copy of the Max
aggregator without its current state.
Return current state to be saved as a map of any
typed values.
Restores the saved state which is passed as a map of any
typed values.
Fields
- iMaxQueue LinkedList BLangTypeInit: new null ([])
-
description
- fMaxQueue LinkedList BLangTypeInit: new null ([])
-
description
- iMax int ()
-
description
- fMax float ()
-
description
Updates the current maximum value and return the updated maximum value.
Parameters
- value anydata
-
Value being checked whether it is greater than the current maximum value.
- eventType EventType
-
Type of the incoming event
streams:CURRENT
,streams:EXPIRED
orstreams:RESET
.
-
Return Type
(anydata) Updated max value.
Returns a copy of the Max
aggregator without its current state.
-
Return Type
(Aggregator) Returns
Max
aggregator.
Return current state to be saved as a map of any
typed values.
-
Return Type
(map) A map of
any
typed values.