Object - streams : AndOperatorProcessor

Processor to perform AND stream operations.

Methods

Fields

  • lhsPartialStates map
  • LHS partially promoted states

  • rhsPartialStates map
  • RHS partially promoted states

  • lhsAlias string lhs
  • LHS processor alias

  • rhsAlias string rhs
  • RHS processor alias

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

validate

Validates the processor and its configs.

promote

Promotes the StreamEvent to the previous processor.

Parameters

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

evict

Evicts the StreamEvent from current state branch.

Parameters

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

remove

Removes a given StreamEvent from the StateMachine.

Parameters

setPreviousProcessor

Sets a link to the previous AbstractOperatorProcessor.

Parameters

setLHSProcessor

Sets a link to the LHS AbstractOperatorProcessor.

Parameters

setRHSProcessor

Sets a link to the RHS AbstractOperatorProcessor.

Parameters

getAlias

()

returns string

Returns the alias of the current processor.

  • Return Type

    (string)
  • alias of the processor.