Package | Description |
---|---|
org.apache.flink.iteration.operator.headprocessor |
Modifier and Type | Field and Description |
---|---|
static HeadOperatorState |
HeadOperatorState.FINISHED_STATE |
Modifier and Type | Field and Description |
---|---|
static org.apache.flink.api.common.typeinfo.TypeInformation<HeadOperatorState> |
HeadOperatorState.TYPE_INFO |
Modifier and Type | Method and Description |
---|---|
HeadOperatorState |
TerminatingHeadOperatorRecordProcessor.snapshotState() |
HeadOperatorState |
RegularHeadOperatorRecordProcessor.snapshotState() |
HeadOperatorState |
HeadOperatorRecordProcessor.snapshotState() |
Modifier and Type | Method and Description |
---|---|
void |
TerminatingHeadOperatorRecordProcessor.initializeState(HeadOperatorState headOperatorState,
Iterable<org.apache.flink.runtime.state.StatePartitionStreamProvider> rawStates) |
void |
RegularHeadOperatorRecordProcessor.initializeState(HeadOperatorState headOperatorState,
Iterable<org.apache.flink.runtime.state.StatePartitionStreamProvider> rawStates) |
void |
HeadOperatorRecordProcessor.initializeState(HeadOperatorState headOperatorState,
Iterable<org.apache.flink.runtime.state.StatePartitionStreamProvider> rawStates) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.