Class

org.apache.flink.api.scala.typeutils

CaseClassComparator

Related Doc: package typeutils

Permalink

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[_]])

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  6. def compare(first: T, second: T): Int

    Permalink
    Definition Classes
    CaseClassComparator → TypeComparator
  7. def compareAgainstReference(arg0: Array[Comparable[_]]): Int

    Permalink
    Definition Classes
    TypeComparator
  8. def compareSerialized(arg0: DataInputView, arg1: DataInputView): Int

    Permalink
    Definition Classes
    TupleComparatorBase → TypeComparator
    Annotations
    @throws( classOf[java.io.IOException] )
  9. def compareToReference(arg0: TypeComparator[T]): Int

    Permalink
    Definition Classes
    TupleComparatorBase → TypeComparator
  10. def duplicate(): TypeComparator[T]

    Permalink
    Definition Classes
    CaseClassComparator → TypeComparator
  11. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  12. def equalToReference(candidate: T): Boolean

    Permalink
    Definition Classes
    CaseClassComparator → TypeComparator
  13. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  14. def extractKeys(value: AnyRef, target: Array[AnyRef], index: Int): Int

    Permalink
    Definition Classes
    CaseClassComparator → TypeComparator
  15. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  17. def getFlatComparator(arg0: List[TypeComparator]): Unit

    Permalink
    Definition Classes
    TupleComparatorBase → CompositeTypeComparator
  18. def getFlatComparators(): Array[TypeComparator]

    Permalink
    Definition Classes
    CompositeTypeComparator → TypeComparator
  19. def getKeyPositions(): Array[Int]

    Permalink
    Attributes
    protected[org.apache.flink.api.java.typeutils.runtime]
    Definition Classes
    TupleComparatorBase
  20. def getNormalizeKeyLen(): Int

    Permalink
    Definition Classes
    TupleComparatorBase → TypeComparator
  21. def hash(value: T): Int

    Permalink
    Definition Classes
    CaseClassComparator → TypeComparator
  22. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  23. final def instantiateDeserializationUtils(): Unit

    Permalink
    Attributes
    protected[org.apache.flink.api.java.typeutils.runtime]
    Definition Classes
    TupleComparatorBase
  24. def invertNormalizedKey(): Boolean

    Permalink
    Definition Classes
    TupleComparatorBase → TypeComparator
  25. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  26. def isNormalizedKeyPrefixOnly(arg0: Int): Boolean

    Permalink
    Definition Classes
    TupleComparatorBase → TypeComparator
  27. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  28. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  29. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  30. def privateDuplicate(arg0: TupleComparatorBase[T]): Unit

    Permalink
    Attributes
    protected[org.apache.flink.api.java.typeutils.runtime]
    Definition Classes
    TupleComparatorBase
  31. def putNormalizedKey(value: T, target: MemorySegment, offsetParam: Int, numBytesParam: Int): Unit

    Permalink
    Definition Classes
    CaseClassComparator → TypeComparator
  32. def readWithKeyDenormalization(arg0: T, arg1: DataInputView): T

    Permalink
    Definition Classes
    TupleComparatorBase → TypeComparator
    Annotations
    @throws( classOf[java.io.IOException] )
  33. def setReference(toCompare: T): Unit

    Permalink
    Definition Classes
    CaseClassComparator → TypeComparator
  34. def supportsCompareAgainstReference(): Boolean

    Permalink
    Definition Classes
    TypeComparator
  35. def supportsNormalizedKey(): Boolean

    Permalink
    Definition Classes
    TupleComparatorBase → TypeComparator
  36. def supportsSerializationWithKeyNormalization(): Boolean

    Permalink
    Definition Classes
    TupleComparatorBase → TypeComparator
  37. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  38. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  39. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  40. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  41. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  42. def writeWithKeyNormalization(arg0: T, arg1: DataOutputView): Unit

    Permalink
    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