Toggle navigation
Home
org.apache.flink.runtime.state.ChainedStateHandle<org.apache.flink.runtime.state.StreamStateHandle> to org.apache.flink.runtime.state.StreamStateHandle
No. of Instances - 13
No. of Commits - 2
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Different)
SubtaskState
to
OperatorSubtaskState
SubtaskState
to
OperatorSubtaskState
SubtaskState
to
OperatorSubtaskState
SubtaskState
to
OperatorSubtaskState
SubtaskState
to
OperatorSubtaskState
SubtaskState
to
OperatorSubtaskState
SubtaskState
to
OperatorSubtaskState
TaskStateHandles
to
OperatorSubtaskState
SubtaskState
to
OperatorSubtaskState
SubtaskState
to
OperatorSubtaskState
Add or Remove Method invocation
CommonTestUtils.isSteamContentEqual(expectSubNonPartitionedState.get(0).openInputStream(),actualSubNonPartitionedState.get(operatorIndexInChain).openInputStream())
to
CommonTestUtils.isSteamContentEqual(expectSubNonPartitionedState.openInputStream(),opState.getLegacyOperatorState().openInputStream())
CommonTestUtils.isSteamContentEqual(expectSubNonPartitionedState.get(0).openInputStream(),actualSubNonPartitionedState.get(operatorIndexInChain).openInputStream())
to
CommonTestUtils.isSteamContentEqual(expectSubNonPartitionedState.openInputStream(),opState.getLegacyOperatorState().openInputStream())
CommonTestUtils.isSteamContentEqual(expectNonPartitionedState.get(0).openInputStream(),actualNonPartitionedState.get(0).openInputStream())
to
CommonTestUtils.isSteamContentEqual(expectNonPartitionedState.openInputStream(),operatorState.getLegacyOperatorState().openInputStream())
Rename Method invocation
generateChainedStateHandle
to
generateStreamStateHandle