Won't add an empty container.

This commit is contained in:
Alex Wheeler 2012-10-24 15:00:20 -04:00
parent 93a4854a4b
commit d1048fc6f2

View file

@ -71,7 +71,7 @@ class LogStash::Filters::KV < LogStash::Filters::Base
return unless filter?(event)
if !@container.nil?
event[@container]=Hash.new
@kv_keys=Hash.new
end
@fields.each do |fieldname|
value = event[fieldname]
@ -84,6 +84,12 @@ class LogStash::Filters::KV < LogStash::Filters::Base
:type => value.type, :value => value)
end # case value
end
if !@container.nil?
# If we didn't add any keys, delete the hash
if @kv_keys.length > 0
event[@container]=@kv_keys
end
end
end # def filter
private
@ -97,7 +103,7 @@ class LogStash::Filters::KV < LogStash::Filters::Base
end
key = @prefix + key
if !@container.nil?
event[@container][key] = value
@kv_keys[key] = value
else
event[key] = value
end