|
Change Variable Type buildSide : HashBucketIterator<IntPair,IntPair> to buildSide : MutableObjectIterator<IntPair> in method public testInMemoryMutableHashTableIntPair() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<IntPair,IntPair> to buildSide : MutableObjectIterator<IntPair> in method public testInMemoryReOpenWithSmallMemory() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : MutableObjectIterator<Record> in method public testSpillingHashJoinOneRecursionPerformance() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : MutableObjectIterator<Record> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSideIterator : MutableHashTable.HashBucketIterator<V2,V1> to buildSideIterator : MutableObjectIterator<V2> in method public callWithNextKey(matchFunction FlatJoinFunction<V1,V2,O>, collector Collector<O>) : boolean in class org.apache.flink.runtime.operators.hash.NonReusingBuildSecondHashJoinIterator |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<IntPair,IntPair> to buildSide : MutableObjectIterator<IntPair> in method public testSpillingHashJoinWithTwoRecursionsIntPair() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>> to buildSide : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildSideIterator : MutableHashTable.HashBucketIterator<V1,V2> to buildSideIterator : MutableObjectIterator<V1> in method public callWithNextKey(matchFunction FlatJoinFunction<V1,V2,O>, collector Collector<O>) : boolean in class org.apache.flink.runtime.operators.hash.ReusingBuildFirstHashJoinIterator |
From |
To |
|
Change Variable Type buildSideIterator : MutableHashTable.HashBucketIterator<V2,V1> to buildSideIterator : MutableObjectIterator<V2> in method public callWithNextKey(matchFunction FlatJoinFunction<V1,V2,O>, collector Collector<O>) : boolean in class org.apache.flink.runtime.operators.hash.ReusingBuildSecondHashJoinIterator |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<IntPair,IntPair> to buildSide : MutableObjectIterator<IntPair> in method public testSparseProbeSpillingIntPair() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<IntPair,IntPair> to buildSide : MutableObjectIterator<IntPair> in method public testSpillingHashJoinOneRecursionValidityIntPair() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<IntPair,IntPair> to buildSide : MutableObjectIterator<IntPair> in method public testSpillingHashJoinOneRecursionPerformanceIntPair() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : MutableObjectIterator<Record> in method public testFailingHashJoinTooManyRecursions() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type iterator : MutableHashTable.HashBucketIterator<byte[],byte[]> to iterator : MutableObjectIterator<byte[]> in method public testSpillingWhenBuildingTableWithoutOverflow() : void in class org.apache.flink.runtime.operators.hash.HashTableTest |
From |
To |
|
Change Variable Type matches : MutableHashTable.HashBucketIterator<Tuple2<Long,byte[]>,Long> to matches : MutableObjectIterator<Tuple2<Long,byte[]>> in method public testBufferMissingForProbing() : void in class org.apache.flink.runtime.operators.hash.HashTableTest |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<IntPair,IntPair> to buildSide : MutableObjectIterator<IntPair> in method public testBucketsNotFulfillSegment() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>> to buildSide : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>> to buildSide : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : MutableObjectIterator<Record> in method public testInMemoryMutableHashTable() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<IntPair,IntPair> to buildSide : MutableObjectIterator<IntPair> in method public validateSpillingDuringInsertionIntPair() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : MutableObjectIterator<Record> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>> to buildSide : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : MutableObjectIterator<Record> in method public testSpillingHashJoinOneRecursionValidity() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : MutableObjectIterator<Record> in method public testSparseProbeSpilling() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type matches : MutableHashTable.HashBucketIterator<Tuple2<Long,byte[]>,Long> to matches : MutableObjectIterator<Tuple2<Long,byte[]>> in method public main(args String[]) : void in class org.apache.flink.test.manual.HashTableRecordWidthCombinations |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : MutableObjectIterator<Record> in method public validateSpillingDuringInsertion() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<IntPair,IntPair> to buildSide : MutableObjectIterator<IntPair> in method public testFailingHashJoinTooManyRecursionsIntPair() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<IntPair,IntPair> to buildSide : MutableObjectIterator<IntPair> in method public testInMemoryReOpen() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type buildSideIterator : MutableHashTable.HashBucketIterator<V1,V2> to buildSideIterator : MutableObjectIterator<V1> in method public callWithNextKey(matchFunction FlatJoinFunction<V1,V2,O>, collector Collector<O>) : boolean in class org.apache.flink.runtime.operators.hash.NonReusingBuildFirstHashJoinIterator |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<IntPair,IntPair> to buildSide : MutableObjectIterator<IntPair> in method public testSpillingHashJoinWithMassiveCollisionsIntPair() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |