Uses of Class
org.apache.flink.api.common.typeutils.TypeComparator

Packages that use TypeComparator

Package	Description
org.apache.flink.api.common.distributions
org.apache.flink.api.common.operators.base
org.apache.flink.api.common.operators.util
org.apache.flink.api.common.typeinfo
org.apache.flink.api.common.typeutils
org.apache.flink.api.common.typeutils.base
org.apache.flink.api.common.typeutils.base.array
org.apache.flink.api.java.typeutils
org.apache.flink.api.java.typeutils.runtime

Uses of TypeComparator in org.apache.flink.api.common.distributions

Constructors in org.apache.flink.api.common.distributions with parameters of type TypeComparator

Constructor	Description
CommonRangeBoundaries(TypeComparator<T> typeComparators, Object[][] boundaries)

Uses of TypeComparator in org.apache.flink.api.common.operators.base

Constructors in org.apache.flink.api.common.operators.base with parameters of type TypeComparator

Constructor	Description
SimpleListIterable(List<IN> values, TypeComparator<IN> comparator, TypeSerializer<IN> serializer)

Uses of TypeComparator in org.apache.flink.api.common.operators.util

Methods in org.apache.flink.api.common.operators.util that return TypeComparator

Modifier and Type	Method	Description
TypeComparator<BT>	JoinHashMap.getBuildComparator()

Methods in org.apache.flink.api.common.operators.util with parameters of type TypeComparator

Modifier and Type	Method	Description
<PT> JoinHashMap.Prober<PT>	JoinHashMap.createProber(TypeComparator<PT> probeComparator, TypePairComparator<PT,BT> pairComparator)

Constructors in org.apache.flink.api.common.operators.util with parameters of type TypeComparator

Constructor	Description
JoinHashMap(TypeSerializer<BT> buildSerializer, TypeComparator<BT> buildComparator)
ListKeyGroupedIterator(List<E> input, TypeSerializer<E> serializer, TypeComparator<E> comparator)	Initializes the ListKeyGroupedIterator..
Prober(TypeComparator<PT> probeComparator, TypePairComparator<PT,BT> pairComparator)
TypeComparable(T elem, TypeComparator<T> comparator)

Uses of TypeComparator in org.apache.flink.api.common.typeinfo

Methods in org.apache.flink.api.common.typeinfo that return TypeComparator

Modifier and Type	Method	Description
TypeComparator<T>	AtomicType.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)	Creates a comparator for this type.
TypeComparator<T>	BasicTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)
TypeComparator<T>	LocalTimeTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)
TypeComparator<T>	SqlTimeTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)

Uses of TypeComparator in org.apache.flink.api.common.typeutils

Subclasses of TypeComparator in org.apache.flink.api.common.typeutils

Modifier and Type	Class	Description
class	CompositeTypeComparator<T>

Methods in org.apache.flink.api.common.typeutils that return TypeComparator

Modifier and Type	Method	Description
TypeComparator<T>	CompositeType.createComparator(int[] logicalKeyFields, boolean[] orders, int logicalFieldOffset, ExecutionConfig config)	Generic implementation of the comparator creation.
TypeComparator<T>	TypeComparatorFactory.createComparator()
TypeComparator<T>	CompositeType.TypeComparatorBuilder.createTypeComparator(ExecutionConfig config)
abstract TypeComparator<T>	TypeComparator.duplicate()	Creates a copy of this class.
TypeComparator[]	CompositeTypeComparator.getFlatComparators()
abstract TypeComparator[]	TypeComparator.getFlatComparators()	Get the field comparators.

Methods in org.apache.flink.api.common.typeutils with parameters of type TypeComparator

Modifier and Type	Method	Description
void	CompositeType.TypeComparatorBuilder.addComparatorField(int fieldId, TypeComparator<?> comparator)
abstract int	TypeComparator.compareToReference(TypeComparator<T> referencedComparator)	This method compares the element that has been set as reference in this type accessor, to the element set as reference in the given type accessor.
TypePairComparator<T1,T2>	TypePairComparatorFactory.createComparator12(TypeComparator<T1> comparator1, TypeComparator<T2> comparator2)
TypePairComparator<T2,T1>	TypePairComparatorFactory.createComparator21(TypeComparator<T1> comparator1, TypeComparator<T2> comparator2)

Method parameters in org.apache.flink.api.common.typeutils with type arguments of type TypeComparator

Modifier and Type	Method	Description
abstract void	CompositeTypeComparator.getFlatComparator(List<TypeComparator> flatComparators)

Constructors in org.apache.flink.api.common.typeutils with parameters of type TypeComparator

Constructor	Description
GenericPairComparator(TypeComparator<T1> comparator1, TypeComparator<T2> comparator2)
SameTypePairComparator(TypeComparator<T> comp)

Uses of TypeComparator in org.apache.flink.api.common.typeutils.base

Subclasses of TypeComparator in org.apache.flink.api.common.typeutils.base

Modifier and Type	Class	Description
class	BasicTypeComparator<T extends Comparable<T>>
class	BigDecComparator	Comparator for comparing BigDecimal values.
class	BigIntComparator	Comparator for comparing BigInteger values.
class	BooleanComparator
class	BooleanValueComparator	Specialized comparator for BooleanValue based on CopyableValueComparator.
class	ByteComparator
class	ByteValueComparator	Specialized comparator for ByteValue based on CopyableValueComparator.
class	CharComparator
class	CharValueComparator	Specialized comparator for CharValue based on CopyableValueComparator.
class	DateComparator
class	DoubleComparator
class	DoubleValueComparator	Specialized comparator for DoubleValue based on CopyableValueComparator.
class	EnumComparator<T extends Enum<T>>
class	FloatComparator
class	FloatValueComparator	Specialized comparator for FloatValue based on CopyableValueComparator.
class	InstantComparator	Comparator for comparing Java Instant.
class	IntComparator
class	IntValueComparator	Specialized comparator for IntValue based on CopyableValueComparator.
class	LocalDateComparator	This class can not extend BasicTypeComparator, because LocalDate is a Comparable of ChronoLocalDate instead of Comparable of LocalDate.
class	LocalDateTimeComparator	This class can not extend BasicTypeComparator, because LocalDateTime is a Comparable of ChronoLocalDateTime instead of Comparable of LocalDateTime.
class	LocalTimeComparator
class	LongComparator
class	LongValueComparator	Specialized comparator for LongValue based on CopyableValueComparator.
class	NullValueComparator	Specialized comparator for NullValue based on CopyableValueComparator.
class	ShortComparator
class	ShortValueComparator	Specialized comparator for ShortValue based on CopyableValueComparator.
class	SqlTimestampComparator	Comparator for comparing Java SQL Timestamps.
class	StringComparator
class	StringValueComparator	Specialized comparator for StringValue based on CopyableValueComparator.

Methods in org.apache.flink.api.common.typeutils.base that return TypeComparator

Modifier and Type	Method	Description
TypeComparator<BooleanValue>	BooleanValueComparator.duplicate()
TypeComparator<ByteValue>	ByteValueComparator.duplicate()
TypeComparator<CharValue>	CharValueComparator.duplicate()
TypeComparator<DoubleValue>	DoubleValueComparator.duplicate()
TypeComparator<FloatValue>	FloatValueComparator.duplicate()
TypeComparator<java.time.Instant>	InstantComparator.duplicate()
TypeComparator<IntValue>	IntValueComparator.duplicate()
TypeComparator<LongValue>	LongValueComparator.duplicate()
TypeComparator<NullValue>	NullValueComparator.duplicate()
TypeComparator<ShortValue>	ShortValueComparator.duplicate()
TypeComparator<StringValue>	StringValueComparator.duplicate()
TypeComparator[]	BasicTypeComparator.getFlatComparators()
TypeComparator<?>[]	BooleanValueComparator.getFlatComparators()
TypeComparator<?>[]	ByteValueComparator.getFlatComparators()
TypeComparator<?>[]	CharValueComparator.getFlatComparators()
TypeComparator<?>[]	DoubleValueComparator.getFlatComparators()
TypeComparator<?>[]	FloatValueComparator.getFlatComparators()
TypeComparator<?>[]	IntValueComparator.getFlatComparators()
TypeComparator[]	LocalDateComparator.getFlatComparators()
TypeComparator[]	LocalDateTimeComparator.getFlatComparators()
TypeComparator<?>[]	LongValueComparator.getFlatComparators()
TypeComparator<?>[]	NullValueComparator.getFlatComparators()
TypeComparator<?>[]	ShortValueComparator.getFlatComparators()
TypeComparator<?>[]	StringValueComparator.getFlatComparators()

Methods in org.apache.flink.api.common.typeutils.base with parameters of type TypeComparator

Modifier and Type	Method	Description
int	BasicTypeComparator.compareToReference(TypeComparator<T> referencedComparator)
int	BooleanValueComparator.compareToReference(TypeComparator<BooleanValue> referencedComparator)
int	ByteValueComparator.compareToReference(TypeComparator<ByteValue> referencedComparator)
int	CharValueComparator.compareToReference(TypeComparator<CharValue> referencedComparator)
int	DoubleValueComparator.compareToReference(TypeComparator<DoubleValue> referencedComparator)
int	FloatValueComparator.compareToReference(TypeComparator<FloatValue> referencedComparator)
int	IntValueComparator.compareToReference(TypeComparator<IntValue> referencedComparator)
int	LocalDateComparator.compareToReference(TypeComparator<java.time.LocalDate> referencedComparator)
int	LocalDateTimeComparator.compareToReference(TypeComparator<java.time.LocalDateTime> referencedComparator)
int	LongValueComparator.compareToReference(TypeComparator<LongValue> referencedComparator)
int	NullValueComparator.compareToReference(TypeComparator<NullValue> referencedComparator)
int	ShortValueComparator.compareToReference(TypeComparator<ShortValue> referencedComparator)
int	StringValueComparator.compareToReference(TypeComparator<StringValue> referencedComparator)

Uses of TypeComparator in org.apache.flink.api.common.typeutils.base.array

Subclasses of TypeComparator in org.apache.flink.api.common.typeutils.base.array

Modifier and Type	Class	Description
class	BooleanPrimitiveArrayComparator
class	BytePrimitiveArrayComparator
class	CharPrimitiveArrayComparator
class	DoublePrimitiveArrayComparator
class	FloatPrimitiveArrayComparator
class	IntPrimitiveArrayComparator
class	LongPrimitiveArrayComparator
class	PrimitiveArrayComparator<T,C extends BasicTypeComparator>
class	ShortPrimitiveArrayComparator

Methods in org.apache.flink.api.common.typeutils.base.array that return TypeComparator

Modifier and Type	Method	Description
TypeComparator<boolean[]>	BooleanPrimitiveArrayComparator.duplicate()
TypeComparator<byte[]>	BytePrimitiveArrayComparator.duplicate()
TypeComparator<char[]>	CharPrimitiveArrayComparator.duplicate()
TypeComparator<double[]>	DoublePrimitiveArrayComparator.duplicate()
TypeComparator<float[]>	FloatPrimitiveArrayComparator.duplicate()
TypeComparator<int[]>	IntPrimitiveArrayComparator.duplicate()
TypeComparator<long[]>	LongPrimitiveArrayComparator.duplicate()
TypeComparator<short[]>	ShortPrimitiveArrayComparator.duplicate()
TypeComparator[]	PrimitiveArrayComparator.getFlatComparators()

Methods in org.apache.flink.api.common.typeutils.base.array with parameters of type TypeComparator

Modifier and Type	Method	Description
int	PrimitiveArrayComparator.compareToReference(TypeComparator<T> referencedComparator)

Uses of TypeComparator in org.apache.flink.api.java.typeutils

Methods in org.apache.flink.api.java.typeutils that return TypeComparator

Modifier and Type	Method	Description
TypeComparator<T>	EnumTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)
TypeComparator<T>	GenericTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)
TypeComparator<Row>	RowTypeInfo.createComparator(int[] logicalKeyFields, boolean[] orders, int logicalFieldOffset, ExecutionConfig config)
TypeComparator<T>	ValueTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)

Uses of TypeComparator in org.apache.flink.api.java.typeutils.runtime

Subclasses of TypeComparator in org.apache.flink.api.java.typeutils.runtime

Modifier and Type	Class	Description
class	CopyableValueComparator<T extends CopyableValue<T> & Comparable<T>>	Comparator for all Value types that extend Key
class	GenericTypeComparator<T extends Comparable<T>>	TypeComparator for all types that extend Comparable.
class	NullAwareComparator<T>	Null-aware comparator that wraps a comparator which does not support null references.
class	PojoComparator<T>
class	RowComparator	Comparator for Row.
class	TupleComparator<T extends Tuple>
class	TupleComparatorBase<T>
class	ValueComparator<T extends Value & Comparable<T>>	Comparator for all Value types that extend Key

Fields in org.apache.flink.api.java.typeutils.runtime declared as TypeComparator

Modifier and Type	Field	Description
protected TypeComparator[]	TupleComparatorBase.comparators	comparators for the key fields, in the same order as the key fields

Methods in org.apache.flink.api.java.typeutils.runtime that return TypeComparator

Modifier and Type	Method	Description
TypeComparator<T>	RuntimeComparatorFactory.createComparator()
TypeComparator<T>	CopyableValueComparator.duplicate()
TypeComparator<T>	GenericTypeComparator.duplicate()
TypeComparator<T>	NullAwareComparator.duplicate()
TypeComparator<Row>	RowComparator.duplicate()
TypeComparator<T>	TupleComparator.duplicate()
TypeComparator<T>	ValueComparator.duplicate()
TypeComparator<?>[]	CopyableValueComparator.getFlatComparators()
TypeComparator[]	GenericTypeComparator.getFlatComparators()
TypeComparator[]	NullAwareComparator.getFlatComparators()
TypeComparator[]	ValueComparator.getFlatComparators()

Methods in org.apache.flink.api.java.typeutils.runtime with parameters of type TypeComparator

Modifier and Type	Method	Description
int	CopyableValueComparator.compareToReference(TypeComparator<T> referencedComparator)
int	GenericTypeComparator.compareToReference(TypeComparator<T> referencedComparator)
int	NullAwareComparator.compareToReference(TypeComparator<T> referencedComparator)
int	PojoComparator.compareToReference(TypeComparator<T> referencedComparator)
int	RowComparator.compareToReference(TypeComparator<Row> referencedComparator)
int	TupleComparatorBase.compareToReference(TypeComparator<T> referencedComparator)
int	ValueComparator.compareToReference(TypeComparator<T> referencedComparator)
TypePairComparator<T1,T2>	RuntimePairComparatorFactory.createComparator12(TypeComparator<T1> comparator1, TypeComparator<T2> comparator2)
TypePairComparator<T2,T1>	RuntimePairComparatorFactory.createComparator21(TypeComparator<T1> comparator1, TypeComparator<T2> comparator2)

Method parameters in org.apache.flink.api.java.typeutils.runtime with type arguments of type TypeComparator

Modifier and Type	Method	Description
void	PojoComparator.getFlatComparator(List<TypeComparator> flatComparators)
void	RowComparator.getFlatComparator(List<TypeComparator> flatComparators)
void	TupleComparatorBase.getFlatComparator(List<TypeComparator> flatComparators)

Constructors in org.apache.flink.api.java.typeutils.runtime with parameters of type TypeComparator

Constructor	Description
NullAwareComparator(TypeComparator<T> wrappedComparator, boolean order)
PojoComparator(Field[] keyFields, TypeComparator<?>[] comparators, TypeSerializer<T> serializer, Class<T> type)
RowComparator(int arity, int[] keyPositions, TypeComparator<Object>[] comparators, TypeSerializer<Object>[] serializers, boolean[] orders)	General constructor for RowComparator.
RuntimeComparatorFactory(TypeComparator<T> comparator)
TupleComparator(int[] keyPositions, TypeComparator<?>[] comparators, TypeSerializer<?>[] serializers)
TupleComparatorBase(int[] keyPositions, TypeComparator<?>[] comparators, TypeSerializer<?>[] serializers)