Object - streams : OperandProcessor

Processor to perform operand processor operations.

Constructor

__init

(string alias, function(map) returns (boolean) onConditionFunc, int minOccurs, int maxOccurs)

  • alias string
  • onConditionFunc function(map) returns (boolean)
  • minOccurs int
  • maxOccurs int

Methods

Fields

  • onConditionFunc function(map) returns (boolean)
  • condition function (i.e [e1.id == id])

  • alias string
  • processor alias

  • minOccurs int 1
  • minimum occurrences of the event

  • maxOccurs int 1
  • maximum occurrences of the event

  • checkRange boolean false
  • is counting pattern

  • lastEvent StreamEvent?
  • if there's counting patterns, lastEvent will accumulate event data.

process

(StreamEvent event, string processorAlias)

returns [boolean, boolean]

Processes the StreamEvent.

Parameters

  • processorAlias string
  • alias for the calling processor, for identification purposes (lhs, rhs).

  • Return Type

    ([boolean, boolean])
  • a tuple indicating, whether the event is promoted and whether to continue to the next processor.

setStateMachine

Set the StateMachine to the procesor and it's descendants.

Parameters

remove

Removes a given StreamEvent from the StateMachine.

Parameters

validate

Validates the processor and its configs.

setPreviousProcessor

Sets a link to the previous AbstractOperatorProcessor.

Parameters

getAlias

()

returns string

Returns the alias of the current processor.

  • Return Type

    (string)
  • alias of the processor.