Skip to content

Commit

Permalink
Remove #filter_stream method
Browse files Browse the repository at this point in the history
Because in v0.14, #filter will be optimized.
So, we can remove this method for v0.14.

see: fluent/fluentd#1145
  • Loading branch information
Hiroshi Hatake authored and cosmo0920 committed Mar 1, 2017
1 parent da9dff9 commit b1defc7
Showing 1 changed file with 0 additions and 8 deletions.
8 changes: 0 additions & 8 deletions lib/fluent/plugin/filter_anonymizer.rb
Original file line number Diff line number Diff line change
Expand Up @@ -174,14 +174,6 @@ def filter(tag, time, record)
record.update(@masks.reduce(record){|r,mask| mask.call(r)})
end

def filter_stream(tag, es)
new_es = Fluent::MultiEventStream.new
es.each do |time, record|
new_es.add(time, @masks.reduce(record){|r,mask| mask.call(r) })
end
new_es
end

def salt_determine(key)
return @salt_map[key] if @salt_map.has_key?(key)
keystr = key.to_s
Expand Down

0 comments on commit b1defc7

Please sign in to comment.