add method and optional variable for optional configuration

Author: ykoyano

lib/embulk/input/bigquery.rb

@@ -26,7 +26,15 @@ def self.transaction(config, &control)
 					keyfile: config[:keyfile],
 					sql: sql,
 					columns: config[:columns],
-					params: params
+					params: params,
+					option: {
+						max: config[:max],
+						cache: config[:cache],
+						timeout: config[:timeout],
+						dryrun:  config[:dryrun]
+						standard_sql: config[:standard_sql],
+						legacy_sql: config[:legacy_sql]
+					}
 				}
 
 				columns = []
@@ -42,7 +50,8 @@ def self.transaction(config, &control)
 			def run
 				bq = Google::Cloud::Bigquery.new(project: @task[:project], keyfile: @task[:keyfile])
 				params = @task[:params]
-				rows = bq.query(@task[:sql])
+				option = keys_to_sym(@task[:option])
+				rows = bq.query(@task[:sql], **option)
 				rows.each do |row|
 					columns = []
 					@task[:columns].each do |c|
@@ -58,6 +67,14 @@ def run
 				@page_builder.finish
 				return {}
 			end
+
+			def keys_to_sym(hash)
+				ret = {}
+				hash.each do |key, value|
+					ret[key.to_sym] = value
+				end
+				ret
+			end
     end
   end
 end