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