Object - streams : OrderBy

The OrderBy object represents the desugared code of order by clause of a streaming query. This object takes 3 parameters to initialize itself. nextProcessPointer is the process method of the next processor. fieldFuncs is an array of function pointers which returns the field values to be sorted. sortTypes is an array of string specifying whether the sort order (ascending or descending). Internally this processor uses a MergeSort object to sort.

Constructor

__init

( function(StreamEvent[]) returns (()) nextProcessorPointer, function(map) returns (anydata) fieldFuncs, string[] sortTypes)

Methods

Fields

  • nextProcessorPointer function(StreamEvent[]) returns (())
  • description

  • fieldFuncs function(map) returns (anydata)
  • description

  • sortTypes string[]
  • description

process

Sorts the given array of stream events according to the given parameters (fieldFuncs and sortTypes).

Parameters

  • streamEvents StreamEvent[]
  • The array of stream events to be sorted.