Object -
streams
:
Filter
The Filter
object represents the where
clause in a streaming query. This object takes two parameter for
initialization. nextProcessorPointer
is the function pointer of the next processor to be invoked once the
filtering is complete. conditionFunc is a function pointer which return true if the given where clause evaluates to
true.
Process the incoming stream events. This function takes an array of stream events, iterate each of the events
in the array, then call the conditionFunc
on each and see if conditionFunc
is evaluates to true. if so,
those events will be passed to the nextPrcessorPointer
which can be the process
function of the next
processor object ( e.g. Select
, Window
, Aggregator
.. etc).
Parameters
- streamEvents StreamEvent[]
-
The events being filtered.