charrington.rb in logstash-output-charrington-0.3.13

- old
+ new

@@ -83,10 +83,12 @@
   config :event_as_json_keyword, validate: :string, default: '@event'
 
   # The database schema
   config :schema, validate: :string, required: false
 
+  config :transformer, validate: :string, default: 'redshift'
+
   def register
     @logger.info('JDBC - Starting up')
 
     load_jar_files!
     @stopping = Concurrent::AtomicBoolean.new(false)
@@ -103,10 +105,11 @@
 
       opts = { connection: connection,
                schema: schema,
                max_retries: @max_flush_exceptions,
                retry_initial_interval: @retry_initial_interval,
-               driver: driver }
+               driver: driver,
+               transformer: @transformer }
       Charrington::Process.call(connection, event, opts)
     rescue => e
       @logger.error("Unable to process event. Event dropped. #{e.message}")
       next
     ensure