class Fluent::Plugin::RewriteFilter
Attributes
rewrite_rule[R]
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/filter_rewrite.rb, line 7 def configure(conf) require 'fluent/plugin/rewrite_rule' super @rewrite_rule = Fluent::RewriteRule.new(self, conf) end
filter_stream(tag, es)
click to toggle source
# File lib/fluent/plugin/filter_rewrite.rb, line 15 def filter_stream(tag, es) new_es = Fluent::MultiEventStream.new es.each do |time, record| record = @rewrite_rule.rewrite(record) new_es.add(time, record) if record end new_es end