lib/embulk/input/lkqd.rb in embulk-input-lkqd-0.7.0 vs lib/embulk/input/lkqd.rb in embulk-input-lkqd-0.8.0

@@ -92,11 +92,13 @@
             next value
           #elsif column_option['type'] == 'timestamp'
           #  next Time.strptime(value + " " + options[:timezone], column_option['format'] + " %Z").to_i
           elsif column_option['type'] == 'long'
             next value.gsub(',','').to_i
-          elsif column_option['type'] == 'double' && value.match(/%$/)
+          elsif column_option['type'] == 'double' && value.match(/%$/) # handle x,xxxx.yy%
             next value.gsub(',','').to_f / 100.0
+          elsif column_option['type'] == 'double' && value.match(/^\$[\d\.,]+$/) # handle $x,xxxx.yy%
+            next value.gsub(/[$,]/,'').to_f / 100.0
           elsif column_option['type'] == 'double'
             next value.gsub(',','').to_f
           else
             next value
           end