Contents

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

module Fluent
  class TypecastFilter < Filter
    Fluent::Plugin.register_filter('typecast', self)

    include ::Fluent::TextParser::TypeConverter

    def filter(tag, time, record)
      filtered = record.map do |key, val|
        [key, convert_type(key, val)]
      end
      Hash[*filtered.flatten(1)]
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-filter_typecast-0.0.3	lib/fluent/plugin/filter_typecast.rb