class CaseClassComparator[T <: Product] extends TupleComparatorBase[T]
Comparator for Case Classes. Access is different from our Java Tuples so we have to treat them differently.
- Annotations
- @Internal()
- Alphabetic
- By Inheritance
- CaseClassComparator
- TupleComparatorBase
- CompositeTypeComparator
- TypeComparator
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new CaseClassComparator(keys: Array[Int], scalaComparators: Array[TypeComparator[_]], scalaSerializers: Array[TypeSerializer[_]])
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
compare(first: T, second: T): Int
- Definition Classes
- CaseClassComparator → TypeComparator
-
def
compareAgainstReference(arg0: Array[Comparable[_]]): Int
- Definition Classes
- TypeComparator
-
def
compareSerialized(arg0: DataInputView, arg1: DataInputView): Int
- Definition Classes
- TupleComparatorBase → TypeComparator
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
compareToReference(arg0: TypeComparator[T]): Int
- Definition Classes
- TupleComparatorBase → TypeComparator
-
def
duplicate(): TypeComparator[T]
- Definition Classes
- CaseClassComparator → TypeComparator
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equalToReference(candidate: T): Boolean
- Definition Classes
- CaseClassComparator → TypeComparator
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
extractKeys(value: AnyRef, target: Array[AnyRef], index: Int): Int
- Definition Classes
- CaseClassComparator → TypeComparator
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getFlatComparator(arg0: List[TypeComparator]): Unit
- Definition Classes
- TupleComparatorBase → CompositeTypeComparator
-
def
getFlatComparators(): Array[TypeComparator]
- Definition Classes
- CompositeTypeComparator → TypeComparator
-
def
getKeyPositions(): Array[Int]
- Attributes
- protected[org.apache.flink.api.java.typeutils.runtime]
- Definition Classes
- TupleComparatorBase
-
def
getNormalizeKeyLen(): Int
- Definition Classes
- TupleComparatorBase → TypeComparator
-
def
hash(value: T): Int
- Definition Classes
- CaseClassComparator → TypeComparator
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
instantiateDeserializationUtils(): Unit
- Attributes
- protected[org.apache.flink.api.java.typeutils.runtime]
- Definition Classes
- TupleComparatorBase
-
def
invertNormalizedKey(): Boolean
- Definition Classes
- TupleComparatorBase → TypeComparator
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isNormalizedKeyPrefixOnly(arg0: Int): Boolean
- Definition Classes
- TupleComparatorBase → TypeComparator
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
privateDuplicate(arg0: TupleComparatorBase[T]): Unit
- Attributes
- protected[org.apache.flink.api.java.typeutils.runtime]
- Definition Classes
- TupleComparatorBase
-
def
putNormalizedKey(value: T, target: MemorySegment, offsetParam: Int, numBytesParam: Int): Unit
- Definition Classes
- CaseClassComparator → TypeComparator
-
def
readWithKeyDenormalization(arg0: T, arg1: DataInputView): T
- Definition Classes
- TupleComparatorBase → TypeComparator
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
setReference(toCompare: T): Unit
- Definition Classes
- CaseClassComparator → TypeComparator
-
def
supportsCompareAgainstReference(): Boolean
- Definition Classes
- TypeComparator
-
def
supportsNormalizedKey(): Boolean
- Definition Classes
- TupleComparatorBase → TypeComparator
-
def
supportsSerializationWithKeyNormalization(): Boolean
- Definition Classes
- TupleComparatorBase → TypeComparator
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
writeWithKeyNormalization(arg0: T, arg1: DataOutputView): Unit
- Definition Classes
- TupleComparatorBase → TypeComparator
- Annotations
- @throws( classOf[java.io.IOException] )