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 



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

def configure(conf)
  super
  @all_empty_values = parse_empty_values_parameter
  @keys_empty_values = nil
  @keys_empty_values = parse_empty_keys_parameter unless @empty_keys.nil?
end

#filter(_tag, _time, record) ⇒ Object 



21
22
23
24
25
26
27
28
29
30
 
# File 'lib/fluent/plugin/filter_empty_keys.rb', line 21

def filter(_tag, _time, record)
  record.reject do |k, v|
    (
      v.nil? ||
      v.to_s.empty? ||
      @all_empty_values.include?(v.to_s) ||
      (!@keys_empty_values.nil? && v.to_s.eql?(@keys_empty_values[k]))
    )
  end
end