class Blocktrain::Aggregation

Public Class Methods

new(options = {}) click to toggle source
Calls superclass method
# File lib/blocktrain/aggregation.rb, line 3
def initialize(options = {})
  @interval = options.fetch(:interval, '10m')
  super
end

Public Instance Methods

aggs() click to toggle source
# File lib/blocktrain/aggregation.rb, line 12
def aggs
  raise RuntimeError.new("Aggregation cannot be used directly. Use a derived class instead like AverageAggregation.")
end
body() click to toggle source
# File lib/blocktrain/aggregation.rb, line 16
def body
  {
    query: query,
    size: 0,
    aggregations: aggs,
  }
end
results() click to toggle source
# File lib/blocktrain/aggregation.rb, line 8
def results
  result['aggregations']
end