class Almicube::Aggregator::AvgAggregator
Protected Instance Methods
sub_aggregate(key)
click to toggle source
# File lib/almicube/aggregator/avg_aggregator.rb, line 6 def sub_aggregate(key) keys = ranking.bundled_keys.select { |k| self.class.connection.zcard(k) > 0 } keys << ranking.selector.interstore if ranking.selector.interstore if keys.length > 0 weights = keys.map { 1/keys.length } self.class.connection.zinterstore(key, keys, weights) end end