Class BucketUtils



  • public class BucketUtils
    extends Object
    Helper functions for common Bucketing functions
    • Constructor Detail

      • BucketUtils

        public BucketUtils()
    • Method Detail

      • suggestShardSideQueueSize

        public static int suggestShardSideQueueSize(int finalSize,
                                                    int numberOfShards)
        Heuristic used to determine the size of shard-side PriorityQueues when selecting the top N terms from a distributed index.
        Parameters:
        finalSize - The number of terms required in the final reduce phase.
        numberOfShards - The number of shards being queried.
        Returns:
        A suggested default for the size of any shard-side PriorityQueues