Contents

require 'fluent/filter'
require 'fluent/parser'

module Fluent
  class EmptyKeysFilter < Filter
    Fluent::Plugin.register_filter('empty_keys', self)

    def filter(tag, time, record)
      record.reject{ |k,v| (v.nil? || v.to_s.empty?) }
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-filter_empty_keys-0.0.2	lib/fluent/plugin/filter_empty_keys.rb