module Fluent::RecordFilterMixin

def filter_record(tag, time, record)
end

def format_stream(tag, es)
  out = ''
  es.each {|time,record|
    tag_temp = tag.dup
    filter_record(tag_temp, time, record)
    out << format(tag_temp, time, record)
  }
  out
end