class Fluent::JSONTransformFilter
Constants
- DEFAULTS
Public Instance Methods
configure(conf)
click to toggle source
# File lib/fluent/plugin/filter_json_transform.rb, line 11 def configure(conf) @transform_script = conf['transform_script'] if DEFAULTS.include?(@transform_script) @transform_script = "#{__dir__}/../../transform/#{@transform_script}.rb" elsif @transform_script == 'custom' @transform_script = conf['script_path'] end require @transform_script @transformer = JSONTransformer.new end
filter(tag, time, record)
click to toggle source
# File lib/fluent/plugin/filter_json_transform.rb, line 24 def filter(tag, time, record) flattened = @transformer.transform(record) return flattened end