flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTable.java
/**
	 * Doubles the capacity of the hash table. Existing entries are placed in
	 * the correct bucket on the enlarged table. If the current capacity is,
	 * MAXIMUM_CAPACITY, this method is a no-op. Returns the table, which
	 * will be new unless we were already at MAXIMUM_CAPACITY.
	 */
Doubles the capacity of the hash table. Existing entries are placed in
the correct bucket on the enlarged table. If the current capacity is,
MAXIMUM_CAPACITY, this method is a no-op. Returns the table, which
will be new unless we were already at MAXIMUM_CAPACITY.
Doubles the capacity of the hash table . Existing entries are placed in the correct bucket on the enlarged table . If the current capacity is MAXIMUM_CAPACITY this method is a no - op . Returns the table which will be new unless we were already at MAXIMUM_CAPACITY .
private void doubleCapacity() {
		Preconditions.checkState(!isRehashing(), "There is already a rehash in progress.");
		StateTableEntry<K, N, S>[] oldTable = primaryTable;
		int oldCapacity = oldTable.length;
		if (oldCapacity == MAXIMUM_CAPACITY) {
			return;
		}
		incrementalRehashTable = makeTable(oldCapacity * 2);
	}
private void doubleCapacity ( ) { Preconditions . checkState ( ! isRehashing ( ) , "There is already a rehash in progress." ) ; StateTableEntry < K , N , S > [ ] oldTable = primaryTable ; int oldCapacity = oldTable . length ; if ( oldCapacity == MAXIMUM_CAPACITY ) { return ; } incrementalRehashTable = makeTable ( oldCapacity * 2 ) ; }
Doubles the capacity of the hash table.
Doubles the capacity of the hash table .
// There can only be one rehash in flight. From the amount of incremental rehash steps we take, this should always hold.