Interface | Description |
---|---|
HeadOperatorRecordProcessor |
The component to actually deal with the event received in the
HeadOperator . |
HeadOperatorRecordProcessor.Context |
The context for
HeadOperatorRecordProcessor . |
Class | Description |
---|---|
HeadOperatorState |
The state entry for the head operator.
|
RegularHeadOperatorRecordProcessor |
Processes the event before we received the terminated global aligned event from the coordinator.
|
TerminatingHeadOperatorRecordProcessor |
Processor used after we received terminated globally aligned event from the coordinator, but
before we received the (Integer.MAX_VALUE + 1) from the feedback channel again.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.