public class HeadOperatorState extends Object
Modifier and Type | Field and Description |
---|---|
static HeadOperatorState |
FINISHED_STATE |
static org.apache.flink.api.common.typeinfo.TypeInformation<HeadOperatorState> |
TYPE_INFO |
Constructor and Description |
---|
HeadOperatorState() |
HeadOperatorState(Map<Integer,Long> numFeedbackRecordsEachRound,
int latestRoundAligned,
int latestRoundGloballyAligned) |
Modifier and Type | Method and Description |
---|---|
int |
getLatestRoundAligned() |
int |
getLatestRoundGloballyAligned() |
Map<Integer,Long> |
getNumFeedbackRecordsEachRound() |
public static final org.apache.flink.api.common.typeinfo.TypeInformation<HeadOperatorState> TYPE_INFO
public static final HeadOperatorState FINISHED_STATE
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.