public interface HeadOperatorRecordProcessor
HeadOperator
.Modifier and Type | Interface and Description |
---|---|
static interface |
HeadOperatorRecordProcessor.Context
The context for
HeadOperatorRecordProcessor . |
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() |
void initializeState(HeadOperatorState headOperatorState, Iterable<org.apache.flink.runtime.state.StatePartitionStreamProvider> rawStates)
void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record)
boolean processFeedbackElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record)
boolean onGloballyAligned(GloballyAlignedEvent globallyAlignedEvent)
@Nullable HeadOperatorState snapshotState()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.