lib/logstash/filters/aggregate.rb
# update "aggregate_maps" metric, with aggregate maps count associated to configured taskid pattern 
update "aggregate_maps" metric, with aggregate maps count associated to configured taskid pattern
update " aggregate_maps " metric with aggregate maps count associated to configured taskid pattern
def update_aggregate_maps_metric()
    aggregate_maps = @current_pipeline.aggregate_maps[@task_id]
    if aggregate_maps
      metric.gauge(:aggregate_maps, aggregate_maps.length)
    end
  end
def update_aggregate_maps_metric ( ) aggregate_maps = @current_pipeline . aggregate_maps [ @task_id ] if aggregate_maps metric . gauge ( :aggregate_maps , aggregate_maps . length ) end end
update "aggregate_maps" metric, with aggregate maps count associated to configured taskid pattern
update " aggregate_maps " metric with aggregate maps count associated to configured taskid pattern