Object - streams : NotOperatorProcessor

Constructor

__init

(int forTimeMillis)

  • forTimeMillis int

Methods

Fields

  • forTimeMillis int -1
  • processorAlias string ()
  • schedulerLock int -1
  • eventSchedulerService service org.wso2.ballerinalang.compiler.tree.expressions.BLangServiceConstructorExpr@1f0bc34a

rescheduleNextEvent

Reschedules the next NOT event.

Parameters

  • delay int
  • delay for the next event

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

setProcessor

Sets a link to the descendant AbstractOperatorProcessor.

Parameters

getAlias

()

returns string

Returns the alias of the current processor.

  • Return Type

    (string)
  • alias of the processor.