Package | Description |
---|---|
org.apache.flink.iteration.operator.headprocessor |
Modifier and Type | Class and Description |
---|---|
class |
RegularHeadOperatorRecordProcessor
Processes the event before we received the terminated global aligned event from the coordinator.
|
class |
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.