Class CompositeTypeComparator<T>
- java.lang.Object
-
- org.apache.flink.api.common.typeutils.TypeComparator<T>
-
- org.apache.flink.api.common.typeutils.CompositeTypeComparator<T>
-
- All Implemented Interfaces:
Serializable
- Direct Known Subclasses:
PojoComparator,RowComparator,TupleComparatorBase
@PublicEvolving public abstract class CompositeTypeComparator<T> extends TypeComparator<T>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CompositeTypeComparator()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract voidgetFlatComparator(List<TypeComparator> flatComparators)TypeComparator[]getFlatComparators()Get the field comparators.-
Methods inherited from class org.apache.flink.api.common.typeutils.TypeComparator
compare, compareAgainstReference, compareSerialized, compareToReference, duplicate, equalToReference, extractKeys, getNormalizeKeyLen, hash, invertNormalizedKey, isNormalizedKeyPrefixOnly, putNormalizedKey, readWithKeyDenormalization, setReference, supportsCompareAgainstReference, supportsNormalizedKey, supportsSerializationWithKeyNormalization, writeWithKeyNormalization
-
-
-
-
Method Detail
-
getFlatComparators
public TypeComparator[] getFlatComparators()
Description copied from class:TypeComparatorGet the field comparators. This is used together withTypeComparator.extractKeys(Object, Object[], int)to provide interoperability between different record types. Note, that this should return at least one Comparator and that the number of Comparators must match the number of extracted keys.- Specified by:
getFlatComparatorsin classTypeComparator<T>- Returns:
- An Array of Comparators for the extracted keys.
-
getFlatComparator
public abstract void getFlatComparator(List<TypeComparator> flatComparators)
-
-