lib/logstash/filters/aggregate.rb
# Extract the previous map in aggregate maps, and return it as a new Logstash event
Extract the previous map in aggregate maps, and return it as a new Logstash event
Extract the previous map in aggregate maps and return it as a new Logstash event
def extract_previous_map_as_event
    previous_entry = @current_pipeline.aggregate_maps[@task_id].shift()
    previous_task_id = previous_entry[0]
    previous_map = previous_entry[1].map
    update_aggregate_maps_metric()
    return create_timeout_event(previous_map, previous_task_id)
  end
def extract_previous_map_as_event previous_entry = @current_pipeline . aggregate_maps [ @task_id ] . shift ( ) previous_task_id = previous_entry [ 0 ] previous_map = previous_entry [ 1 ] . map update_aggregate_maps_metric ( ) return create_timeout_event ( previous_map , previous_task_id ) end
Extract the previous map in aggregate maps, and return it as a new Logstash event
Extract the previous map in aggregate maps and return it as a new Logstash event