public static interface HeadOperatorRecordProcessor.Context
HeadOperatorRecordProcessor
.Modifier and Type | Method and Description |
---|---|
void |
broadcastOutput(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
org.apache.flink.streaming.api.graph.StreamConfig |
getStreamConfig() |
org.apache.flink.api.common.TaskInfo |
getTaskInfo() |
void |
notifyTerminatingOnInitialize() |
void |
output(org.apache.flink.util.OutputTag<IterationRecord<?>> outputTag,
org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
void |
output(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
void |
updateEpochToCoordinator(int epoch,
long numFeedbackRecords) |
org.apache.flink.streaming.api.graph.StreamConfig getStreamConfig()
org.apache.flink.api.common.TaskInfo getTaskInfo()
void output(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record)
void output(org.apache.flink.util.OutputTag<IterationRecord<?>> outputTag, org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record)
void broadcastOutput(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record)
void updateEpochToCoordinator(int epoch, long numFeedbackRecords)
void notifyTerminatingOnInitialize()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.