Interface PartitionFetcher.Context.ComparablePartitionValue<P,​T extends Comparable<T>>

  • Type Parameters:
    P - The type of partition value.
    T - The tye of the partition offset, the partition offset is comparable.
    All Superinterfaces:
    Serializable
    Enclosing interface:
    PartitionFetcher.Context<P>

    public static interface PartitionFetcher.Context.ComparablePartitionValue<P,​T extends Comparable<T>>
    extends Serializable
    A comparable partition value that can compare order by using its comparator.
    • Method Detail

      • getPartitionValue

        P getPartitionValue()
        Get the partition value.
      • getComparator

        T getComparator()
        Get the comparator.
        Returns: