public class RegularHeadOperatorRecordProcessor extends Object implements HeadOperatorRecordProcessor
HeadOperatorRecordProcessor.Context
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
RegularHeadOperatorRecordProcessor(HeadOperatorRecordProcessor.Context headOperatorContext) |
Modifier and Type | Method and Description |
---|---|
int |
getLatestRoundAligned() |
int |
getLatestRoundGloballyAligned() |
Map<Integer,Long> |
getNumFeedbackRecordsPerEpoch() |
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<?>> element) |
boolean |
processFeedbackElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> element) |
HeadOperatorState |
snapshotState() |
public RegularHeadOperatorRecordProcessor(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<?>> element)
processElement
in interface HeadOperatorRecordProcessor
public boolean processFeedbackElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> element)
processFeedbackElement
in interface HeadOperatorRecordProcessor
public boolean onGloballyAligned(GloballyAlignedEvent globallyAlignedEvent)
onGloballyAligned
in interface HeadOperatorRecordProcessor
public HeadOperatorState snapshotState()
snapshotState
in interface HeadOperatorRecordProcessor
@VisibleForTesting public Map<Integer,Long> getNumFeedbackRecordsPerEpoch()
@VisibleForTesting public int getLatestRoundAligned()
@VisibleForTesting public int getLatestRoundGloballyAligned()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.