public class TerminatingHeadOperatorRecordProcessor extends Object implements HeadOperatorRecordProcessor
HeadOperatorRecordProcessor.Context
Constructor and Description |
---|
TerminatingHeadOperatorRecordProcessor(HeadOperatorRecordProcessor.Context headOperatorContext) |
Modifier and Type | Method and Description |
---|---|
void |
initializeState(HeadOperatorState headOperatorState,
Iterable<org.apache.flink.runtime.state.StatePartitionStreamProvider> rawStates) |
boolean |
onGloballyAligned(GloballyAlignedEvent globallyAlignedEvent) |
void |
processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
boolean |
processFeedbackElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
HeadOperatorState |
snapshotState() |
public TerminatingHeadOperatorRecordProcessor(HeadOperatorRecordProcessor.Context headOperatorContext)
public void initializeState(HeadOperatorState headOperatorState, Iterable<org.apache.flink.runtime.state.StatePartitionStreamProvider> rawStates)
initializeState
in interface HeadOperatorRecordProcessor
public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record)
processElement
in interface HeadOperatorRecordProcessor
public boolean processFeedbackElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record)
processFeedbackElement
in interface HeadOperatorRecordProcessor
public boolean onGloballyAligned(GloballyAlignedEvent globallyAlignedEvent)
onGloballyAligned
in interface HeadOperatorRecordProcessor
public HeadOperatorState snapshotState()
snapshotState
in interface HeadOperatorRecordProcessor
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.