Class LLCUtils


  • public class LLCUtils
    extends Object
    • Method Detail

      • sortSegmentsByStreamPartition

        public static Map<String,​SortedSet<SegmentName>> sortSegmentsByStreamPartition​(Set<String> segmentSet)
        Compute the table of a sorted list of segments grouped by Kafka partition.
        Parameters:
        segmentSet - is the set of segment names that need to be sorted.
        Returns:
        map of Stream partition to sorted set of segment names