Packages

c

org.apache.flink.api.scala.typeutils

CaseClassComparator

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()
Linear Supertypes
TupleComparatorBase[T], CompositeTypeComparator[T], TypeComparator[T], Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CaseClassComparator
  2. TupleComparatorBase
  3. CompositeTypeComparator
  4. TypeComparator
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new CaseClassComparator(keys: Array[Int], scalaComparators: Array[TypeComparator[_]], scalaSerializers: Array[TypeSerializer[_]])

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  6. def compare(first: T, second: T): Int
    Definition Classes
    CaseClassComparator → TypeComparator
  7. def compareAgainstReference(arg0: Array[Comparable[_]]): Int
    Definition Classes
    TypeComparator
  8. def compareSerialized(arg0: DataInputView, arg1: DataInputView): Int
    Definition Classes
    TupleComparatorBase → TypeComparator
    Annotations
    @throws( classOf[java.io.IOException] )
  9. def compareToReference(arg0: TypeComparator[T]): Int
    Definition Classes
    TupleComparatorBase → TypeComparator
  10. def duplicate(): TypeComparator[T]
    Definition Classes
    CaseClassComparator → TypeComparator
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equalToReference(candidate: T): Boolean
    Definition Classes
    CaseClassComparator → TypeComparator
  13. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  14. def extractKeys(value: AnyRef, target: Array[AnyRef], index: Int): Int
    Definition Classes
    CaseClassComparator → TypeComparator
  15. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. def getFlatComparator(arg0: List[TypeComparator]): Unit
    Definition Classes
    TupleComparatorBase → CompositeTypeComparator
  18. def getFlatComparators(): Array[TypeComparator]
    Definition Classes
    CompositeTypeComparator → TypeComparator
  19. def getKeyPositions(): Array[Int]
    Attributes
    protected[org.apache.flink.api.java.typeutils.runtime]
    Definition Classes
    TupleComparatorBase
  20. def getNormalizeKeyLen(): Int
    Definition Classes
    TupleComparatorBase → TypeComparator
  21. def hash(value: T): Int
    Definition Classes
    CaseClassComparator → TypeComparator
  22. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  23. final def instantiateDeserializationUtils(): Unit
    Attributes
    protected[org.apache.flink.api.java.typeutils.runtime]
    Definition Classes
    TupleComparatorBase
  24. def invertNormalizedKey(): Boolean
    Definition Classes
    TupleComparatorBase → TypeComparator
  25. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  26. def isNormalizedKeyPrefixOnly(arg0: Int): Boolean
    Definition Classes
    TupleComparatorBase → TypeComparator
  27. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  28. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  29. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  30. def privateDuplicate(arg0: TupleComparatorBase[T]): Unit
    Attributes
    protected[org.apache.flink.api.java.typeutils.runtime]
    Definition Classes
    TupleComparatorBase
  31. def putNormalizedKey(value: T, target: MemorySegment, offsetParam: Int, numBytesParam: Int): Unit
    Definition Classes
    CaseClassComparator → TypeComparator
  32. def readWithKeyDenormalization(arg0: T, arg1: DataInputView): T
    Definition Classes
    TupleComparatorBase → TypeComparator
    Annotations
    @throws( classOf[java.io.IOException] )
  33. def setReference(toCompare: T): Unit
    Definition Classes
    CaseClassComparator → TypeComparator
  34. def supportsCompareAgainstReference(): Boolean
    Definition Classes
    TypeComparator
  35. def supportsNormalizedKey(): Boolean
    Definition Classes
    TupleComparatorBase → TypeComparator
  36. def supportsSerializationWithKeyNormalization(): Boolean
    Definition Classes
    TupleComparatorBase → TypeComparator
  37. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  38. def toString(): String
    Definition Classes
    AnyRef → Any
  39. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  40. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  41. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  42. def writeWithKeyNormalization(arg0: T, arg1: DataOutputView): Unit
    Definition Classes
    TupleComparatorBase → TypeComparator
    Annotations
    @throws( classOf[java.io.IOException] )

Inherited from TupleComparatorBase[T]

Inherited from CompositeTypeComparator[T]

Inherited from TypeComparator[T]

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped