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