class LogStash::Inputs::BeatsSupport::DecodedEventTransform

def transform(event, hash)
  ts = coerce_ts(hash.delete("@timestamp"))
  event.set("@timestamp", ts) unless ts.nil?
  hash.each { |k, v| event.set(k, v) }
  super(event)
  event.tag("beats_input_codec_#{codec_name}_applied")
  event
end