Package org.apache.flink.api.java.typeutils.runtime

Class WritableComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

  • Type Parameters:
    T -
    All Implemented Interfaces:
    Serializable
    @Internal
public class WritableComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>
extends org.apache.flink.api.common.typeutils.TypeComparator<T>
    A TypeComparator for Writable.
    See Also:
    Serialized Form

    • Constructor Detail

      • WritableComparator

        public WritableComparator​(boolean ascending,
                          Class<T> type)

    • Method Detail

      • hash

        public int hash​(T record)
        Specified by:
        hash in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • setReference

        public void setReference​(T toCompare)
        Specified by:
        setReference in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • equalToReference

        public boolean equalToReference​(T candidate)
        Specified by:
        equalToReference in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • compareToReference

        public int compareToReference​(org.apache.flink.api.common.typeutils.TypeComparator<T> referencedComparator)
        Specified by:
        compareToReference in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • compare

        public int compare​(T first,
                   T second)
        Specified by:
        compare in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • compareSerialized

        public int compareSerialized​(org.apache.flink.core.memory.DataInputView firstSource,
                             org.apache.flink.core.memory.DataInputView secondSource)
                      throws IOException
        Specified by:
        compareSerialized in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>
        Throws:
        IOException

      • supportsNormalizedKey

        public boolean supportsNormalizedKey()
        Specified by:
        supportsNormalizedKey in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • getNormalizeKeyLen

        public int getNormalizeKeyLen()
        Specified by:
        getNormalizeKeyLen in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • isNormalizedKeyPrefixOnly

        public boolean isNormalizedKeyPrefixOnly​(int keyBytes)
        Specified by:
        isNormalizedKeyPrefixOnly in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • putNormalizedKey

        public void putNormalizedKey​(T record,
                             org.apache.flink.core.memory.MemorySegment target,
                             int offset,
                             int numBytes)
        Specified by:
        putNormalizedKey in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • invertNormalizedKey

        public boolean invertNormalizedKey()
        Specified by:
        invertNormalizedKey in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • duplicate

        public org.apache.flink.api.common.typeutils.TypeComparator<T> duplicate()
        Specified by:
        duplicate in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • extractKeys

        public int extractKeys​(Object record,
                       Object[] target,
                       int index)
        Specified by:
        extractKeys in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • getFlatComparators

        public org.apache.flink.api.common.typeutils.TypeComparator[] getFlatComparators()
        Specified by:
        getFlatComparators in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • supportsSerializationWithKeyNormalization

        public boolean supportsSerializationWithKeyNormalization()
        Specified by:
        supportsSerializationWithKeyNormalization in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>

      • writeWithKeyNormalization

        public void writeWithKeyNormalization​(T record,
                                      org.apache.flink.core.memory.DataOutputView target)
                               throws IOException
        Specified by:
        writeWithKeyNormalization in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>
        Throws:
        IOException

      • readWithKeyDenormalization

        public T readWithKeyDenormalization​(T reuse,
                                    org.apache.flink.core.memory.DataInputView source)
                             throws IOException
        Specified by:
        readWithKeyDenormalization in class org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>
        Throws:
        IOException