|
Change Parameter Type types1 : Class<? extends Key<?>>[] to types1 : Class<? extends Value>[] in method private checkComparators(pos1 int[], pos2 int[], types1 Class<? extends Value>[], types2 Class<? extends Value>[]) : void in class org.apache.flink.runtime.testutils.recordutils.RecordPairComparatorFactory |
From |
To |
|
Change Parameter Type type : Class<? extends Key<?>> to type : Class<? extends Comparable<?>> in method public Ordering(index int, type Class<? extends Comparable<?>>, order Order) in class org.apache.flink.api.common.operators.Ordering |
From |
To |
|
Change Parameter Type types2 : Class<? extends Key<?>>[] to types2 : Class<? extends Value>[] in method private checkComparators(pos1 int[], pos2 int[], types1 Class<? extends Value>[], types2 Class<? extends Value>[]) : void in class org.apache.flink.runtime.testutils.recordutils.RecordPairComparatorFactory |
From |
To |
|
Change Parameter Type types : Class<? extends Key<?>>[] to types : Class<? extends Value>[] in method public RecordComparatorFactory(positions int[], types Class<? extends Value>[], sortDirections boolean[]) in class org.apache.flink.runtime.testutils.recordutils.RecordComparatorFactory |
From |
To |
|
Change Parameter Type keyTypes : Class<? extends Key<?>>[] to keyTypes : Class<? extends Value>[] in method public RecordComparator(keyFields int[], keyTypes Class<? extends Value>[]) in class org.apache.flink.runtime.testutils.recordutils.RecordComparator |
From |
To |
|
Change Parameter Type keyTypes : Class<? extends Key<?>>[] to keyTypes : Class<? extends Value>[] in method public RecordComparator(keyFields int[], keyTypes Class<? extends Value>[], sortDirection boolean[]) in class org.apache.flink.runtime.testutils.recordutils.RecordComparator |
From |
To |
|
Change Parameter Type type : Class<? extends Key<?>> to type : Class<? extends Comparable<?>> in method public appendOrdering(index Integer, type Class<? extends Comparable<?>>, order Order) : Ordering in class org.apache.flink.api.common.operators.Ordering |
From |
To |
|
Change Parameter Type types : Class<? extends Key<?>>[] to types : Class<? extends Value>[] in method public RecordComparatorFactory(positions int[], types Class<? extends Value>[]) in class org.apache.flink.runtime.testutils.recordutils.RecordComparatorFactory |
From |
To |
|
Change Parameter Type keyTypes : Class<? extends Key<?>>[] to keyTypes : Class<? extends Value>[] in method public RecordPairComparator(keyFieldsReference int[], keyFieldsCandidate int[], keyTypes Class<? extends Value>[]) in class org.apache.flink.runtime.testutils.recordutils.RecordPairComparator |
From |
To |
|
Change Variable Type types1 : Class<? extends Key<?>>[] to types1 : Class<? extends Value>[] in method public createComparator12(comparator1 TypeComparator<Record>, comparator2 TypeComparator<Record>) : TypePairComparator<Record,Record> in class org.apache.flink.runtime.testutils.recordutils.RecordPairComparatorFactory |
From |
To |
|
Change Variable Type types2 : Class<? extends Key<?>>[] to types2 : Class<? extends Value>[] in method public createComparator12(comparator1 TypeComparator<Record>, comparator2 TypeComparator<Record>) : TypePairComparator<Record,Record> in class org.apache.flink.runtime.testutils.recordutils.RecordPairComparatorFactory |
From |
To |
|
Change Variable Type k : Key<?> to k : Value in method public equalToReference(candidate Record) : boolean in class org.apache.flink.runtime.testutils.recordutils.RecordComparator |
From |
To |
|
Change Variable Type types1 : Class<? extends Key<?>>[] to types1 : Class<? extends Value>[] in method public createComparator21(comparator1 TypeComparator<Record>, comparator2 TypeComparator<Record>) : TypePairComparator<Record,Record> in class org.apache.flink.runtime.testutils.recordutils.RecordPairComparatorFactory |
From |
To |
|
Change Variable Type k : Key to k : Comparable in method public compareToReference(candidate Record) : int in class org.apache.flink.runtime.testutils.recordutils.RecordPairComparator |
From |
To |
|
Change Variable Type types : Class<? extends Key<?>>[] to types : Class<? extends Value>[] in method public readParametersFromConfig(config Configuration, cl ClassLoader) : void in class org.apache.flink.runtime.testutils.recordutils.RecordComparatorFactory |
From |
To |
|
Change Variable Type types2 : Class<? extends Key<?>>[] to types2 : Class<? extends Value>[] in method public createComparator21(comparator1 TypeComparator<Record>, comparator2 TypeComparator<Record>) : TypePairComparator<Record,Record> in class org.apache.flink.runtime.testutils.recordutils.RecordPairComparatorFactory |
From |
To |
|
Change Variable Type k : Key<?> to k : Value in method public RecordComparator(keyFields int[], keyTypes Class<? extends Value>[], sortDirection boolean[]) in class org.apache.flink.runtime.testutils.recordutils.RecordComparator |
From |
To |
|
Change Variable Type k : Key to k : Value in method public equalToReference(candidate Record) : boolean in class org.apache.flink.runtime.testutils.recordutils.RecordPairComparator |
From |
To |
|
Change Variable Type keyTypes : Class<? extends Key<?>>[] to keyTypes : Class<? extends Value>[] in method public getKeyTypes() : Class<? extends Value>[] in class org.apache.flink.runtime.testutils.recordutils.RecordComparator |
From |
To |
|
Change Variable Type k2 : Key to k2 : Comparable in method public compareSerialized(source1 DataInputView, source2 DataInputView) : int in class org.apache.flink.runtime.testutils.recordutils.RecordComparator |
From |
To |
|
Change Variable Type k1 : Key to k1 : Comparable in method public compare(first Record, second Record) : int in class org.apache.flink.runtime.testutils.recordutils.RecordComparator |
From |
To |
|
Change Variable Type k2 : Key to k2 : Comparable in method public compare(first Record, second Record) : int in class org.apache.flink.runtime.testutils.recordutils.RecordComparator |
From |
To |
|
Change Variable Type keyType : Class<? extends Key<?>>[] to keyType : Class<? extends Value>[] in method public setup() : void in class org.apache.flink.runtime.operators.hash.HashTableITCase |
From |
To |
|
Change Variable Type k1 : Key to k1 : Comparable in method public compareSerialized(source1 DataInputView, source2 DataInputView) : int in class org.apache.flink.runtime.testutils.recordutils.RecordComparator |
From |
To |
|
Change Attribute Type keyHolders1 : Key[] to keyHolders1 : Value[] in class org.apache.flink.runtime.testutils.recordutils.RecordPairComparator |
From |
To |
|
Change Attribute Type keyHolders2 : Key[] to keyHolders2 : Value[] in class org.apache.flink.runtime.testutils.recordutils.RecordPairComparator |
From |
To |
|
Change Attribute Type types : Class<? extends Key<?>>[] to types : Class<? extends Value>[] in class org.apache.flink.runtime.testutils.recordutils.RecordComparatorFactory |
From |
To |
|
Change Attribute Type types : ArrayList<Class<? extends Key<?>>> to types : ArrayList<Class<? extends Comparable<?>>> in class org.apache.flink.api.common.operators.Ordering |
From |
To |
|
Change Attribute Type keyHolders : Key[] to keyHolders : Value[] in class org.apache.flink.runtime.testutils.recordutils.RecordComparator |
From |
To |
|
Change Attribute Type transientKeyHolders : Key[] to transientKeyHolders : Value[] in class org.apache.flink.runtime.testutils.recordutils.RecordComparator |
From |
To |