flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java
/**
	 * Extracts certain key group ranges from the given state handles and adds them to the collector.
	 */
Extracts certain key group ranges from the given state handles and adds them to the collector.
Extracts certain key group ranges from the given state handles and adds them to the collector .
private static void extractIntersectingState(
		Collection<KeyedStateHandle> originalSubtaskStateHandles,
		KeyGroupRange rangeToExtract,
		List<KeyedStateHandle> extractedStateCollector) {
		for (KeyedStateHandle keyedStateHandle : originalSubtaskStateHandles) {
			if (keyedStateHandle != null) {
				KeyedStateHandle intersectedKeyedStateHandle = keyedStateHandle.getIntersection(rangeToExtract);
				if (intersectedKeyedStateHandle != null) {
					extractedStateCollector.add(intersectedKeyedStateHandle);
				}
			}
		}
	}
private static void extractIntersectingState ( Collection < KeyedStateHandle > originalSubtaskStateHandles , KeyGroupRange rangeToExtract , List < KeyedStateHandle > extractedStateCollector ) { for ( KeyedStateHandle keyedStateHandle : originalSubtaskStateHandles ) { if ( keyedStateHandle != null ) { KeyedStateHandle intersectedKeyedStateHandle = keyedStateHandle . getIntersection ( rangeToExtract ) ; if ( intersectedKeyedStateHandle != null ) { extractedStateCollector . add ( intersectedKeyedStateHandle ) ; } } } }
Extracts certain key group ranges from the given state handles and adds them to the collector.
Extracts certain key group ranges from the given state handles and adds them to the collector .