Class: Fluent::ParsePostfixFilter
- Inherits:
-
Filter
- Object
- Filter
- Fluent::ParsePostfixFilter
- Defined in:
- lib/fluent/plugin/filter_parse_postfix.rb
Instance Method Summary collapse
Instance Method Details
#filter_stream(tag, es) ⇒ Object
16 17 18 19 20 21 22 23 24 |
# File 'lib/fluent/plugin/filter_parse_postfix.rb', line 16 def filter_stream(tag, es) result_es = Fluent::MultiEventStream.new es.each do |time, record| parse_postfix(time, record, result_es) end result_es end |