Merge pull request #4 from YujiKoyano/bug-fix/access-rows-with-symbol-2

add-method-converting-string-to-symbol

Author: ykoyano

lib/embulk/input/bigquery.rb

@@ -50,6 +50,7 @@ def self.transaction(config, &control)
 			def run
 				bq = Google::Cloud::Bigquery.new(project: @task[:project], keyfile: @task[:keyfile])
 				params = @task[:params]
+				@task[:columns] = values_to_sym(@task[:columns], 'name')
 				option = keys_to_sym(@task[:option])
 				rows = bq.query(@task[:sql], **option)
 				rows.each do |row|
@@ -68,7 +69,13 @@ def run
 				return {}
 			end
 
-			def keys_to_sym(hash)
+			def values_to_sym(hashs, key)
+				hashs.map do |h|
+					h[key] = h[key].to_sym
+					h
+				end
+
+      def keys_to_sym(hash)
 				ret = {}
 				hash.each do |key, value|
 					ret[key.to_sym] = value