Class: Fluent::EmptyKeysFilter

Inherits:
Filter
  • Object
show all
Defined in:
lib/fluent/plugin/filter_empty_keys.rb

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



12
13
14
15
16
17
 
# File 'lib/fluent/plugin/filter_empty_keys.rb', line 12

def configure(conf)
    super

    @keys_empty_values = nil
    @keys_empty_values = parse_empty_values_parameter unless @empty_keys.nil?
end

#filter(tag, time, record) ⇒ Object 



19
20
21
 
# File 'lib/fluent/plugin/filter_empty_keys.rb', line 19

def filter(tag, time, record)
  record.reject{ |k,v| (v.nil? || v.to_s.empty? || (!@keys_empty_values.nil? && v.to_s.eql?(@keys_empty_values[k]))) }
end