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

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.