Interface Grouper.KeySerdeFactory<T>

Enclosing interface:
Grouper<KeyType>

public static interface Grouper.KeySerdeFactory<T>
  • Method Details

    • getMaxDictionarySize

      long getMaxDictionarySize()
      Return max dictionary size threshold.
      Returns:
      max dictionary size
    • factorize

      Grouper.KeySerde<T> factorize()
      Create a new Grouper.KeySerde, which may be stateful.
    • factorizeWithDictionary

      Grouper.KeySerde<T> factorizeWithDictionary(List<String> dictionary)
      Create a new Grouper.KeySerde with the given dictionary.
    • copyKey

      T copyKey(T key)
      Copies a key. Required if the key from an Grouper.Entry from Grouper.iterator(boolean) will be retained past the following call to next().
    • objectComparator

      Comparator<Grouper.Entry<T>> objectComparator(boolean forceDefaultOrder)
      Return an object that knows how to compare two serialized key instances. Will be called by the Grouper.iterator(boolean) method if sorting is enabled.
      Parameters:
      forceDefaultOrder - Return a comparator that sorts by the key in default lexicographic ascending order, regardless of any other conditions (e.g., presence of OrderBySpecs).
      Returns:
      comparator for key objects.