lib/logstash/outputs/csv.rb in logstash-output-csv-2.0.0 vs lib/logstash/outputs/csv.rb in logstash-output-csv-2.0.1
- old
+ new
@@ -29,10 +29,10 @@
@csv_options = Hash[@csv_options.map{|(k, v)|[k.to_sym, v]}]
end
public
def receive(event)
- return unless output?(event)
+
path = event.sprintf(@path)
fd = open(path)
csv_values = @fields.map {|name| get_value(name, event)}
fd.write(csv_values.to_csv(@csv_options))