org.apache.flink.iteration.operator.headprocessor

Interfaces

• HeadOperatorRecordProcessor
• HeadOperatorRecordProcessor.Context

Classes

• HeadOperatorState
• RegularHeadOperatorRecordProcessor
• TerminatingHeadOperatorRecordProcessor