lib/fluent/plugin/out_cassandra_driver.rb in fluent-plugin-cassandra-driver-0.0.5 vs lib/fluent/plugin/out_cassandra_driver.rb in fluent-plugin-cassandra-driver-0.0.7

@@ -1,10 +1,8 @@
 require 'cassandra'
 require 'msgpack'
 require 'json'
-require 'mutators/string_mutator'
-require 'mutators/timeuuid_mutator'
 
 module Fluent
   class CassandraCqlOutput < BufferedOutput
     Fluent::Plugin.register_output('cassandra_driver', self)
 
@@ -90,10 +88,10 @@
         type = self.schema[schema_keys[index]]
 
         case type
           when :string
             value = "'#{value}'"
-          when 'timeuuid'
+          when :timeuuid
             value = Cassandra::Uuid::Generator.new.at(value).to_s
           else
         end
 
         value