flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
/**
	 * Snapshots the timers (both processing and event time ones) for a given {@code keyGroupIdx}.
	 *
	 * @param keyGroupIdx the id of the key-group to be put in the snapshot.
	 * @return a snapshot containing the timers for the given key-group, and the serializers for them
	 */
Snapshots the timers (both processing and event time ones) for a given  keyGroupIdx.
@param keyGroupIdx the id of the key-group to be put in the snapshot.
@return a snapshot containing the timers for the given key-group, and the serializers for them
Snapshots the timers ( both processing and event time ones ) for a given keyGroupIdx . @param keyGroupIdx the id of the key - group to be put in the snapshot . @return a snapshot containing the timers for the given key - group and the serializers for them
public InternalTimersSnapshot<K, N> snapshotTimersForKeyGroup(int keyGroupIdx) {
		return new InternalTimersSnapshot<>(
				keySerializer,
				keySerializer.snapshotConfiguration(),
				namespaceSerializer,
				namespaceSerializer.snapshotConfiguration(),
				getEventTimeTimerSetForKeyGroup(keyGroupIdx),
				getProcessingTimeTimerSetForKeyGroup(keyGroupIdx));
	}
public InternalTimersSnapshot < K , N > snapshotTimersForKeyGroup ( int keyGroupIdx ) { return new InternalTimersSnapshot < > ( keySerializer , keySerializer . snapshotConfiguration ( ) , namespaceSerializer , namespaceSerializer . snapshotConfiguration ( ) , getEventTimeTimerSetForKeyGroup ( keyGroupIdx ) , getProcessingTimeTimerSetForKeyGroup ( keyGroupIdx ) ) ; }
Snapshots the timers (both processing and event time ones) for a given {@code keyGroupIdx}.
Snapshots the timers ( both processing and event time ones ) for a given { @code keyGroupIdx } .