create_redshift_table.rb in logstash-output-charrington-0.3.13

- old
+ new

@@ -5,16 +5,16 @@
     # This service will create a table dynamically based on the JSON structure.
     # This is potentially called from Insert when an insert fails.
 
     include Service
     include LogStash::Util::Loggable
-    attr_reader :connection, :event, :table_name, :columns, :schema
+    attr_reader :connection, :event, :table_name, :columns, :schema, :opts
     attr_accessor :column_types
 
     Error = Class.new(StandardError)
     CreateFailed = Class.new(Error)
 
-    def initialize(connection, event, schema, table_name, columns)
+    def initialize(connection, event, schema, table_name, columns, opts = {})
       @connection = connection
       @event = event.to_hash
       @schema = schema
       @table_name = table_name
       @columns = columns