Interface KeyExtractor

  • All Superinterfaces:
    java.io.Serializable
    All Known Implementing Classes:
    PairKeyExtractor, SparkKeyExtractor

    public interface KeyExtractor
    extends java.io.Serializable
    Extracts a key from an element. Keys are used for partitioning.
    • Method Detail

      • extractKey

        java.lang.Object extractKey​(java.lang.Object element)
        Extracts key.
        Parameters:
        element - Element to get the key from.
        Returns:
        The extracted key of the element.