Object -
streams :
Min
Aggregator to find the minimum value in a stream.
Methods
Updates the current minimum value and return the updated minimum value.
Returns a copy of the Min
aggregator.
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
- iMinQueue LinkedList BLangTypeInit: new null ([])
-
description
- fMinQueue LinkedList BLangTypeInit: new null ([])
-
description
- iMin int? ()
-
description
- fMin float? ()
-
description
Updates the current minimum value and return the updated minimum value.
Parameters
- value anydata
-
Value being checked whether it is lesser than the current minimum value.
- eventType EventType
-
Type of the incoming event
streams:CURRENT
,streams:EXPIRED
orstreams:RESET
.
-
Return Type
(anydata) Updated minimum value.
Returns a copy of the Min
aggregator.
-
Return Type
(Aggregator) A
Aggregator
object which representsMin
aggregator.
Return current state to be saved as a map of any
typed values.
-
Return Type
(map) A map of
any
typed values.
Restores the saved state which is passed as a map of any
typed values.
Parameters
- state map
-
A map of typed
any
values. This map contains the values to be restored from the persisted data.