class Tumugi::Plugin::BigqueryQueryTask
Public Instance Methods
completed?()
click to toggle source
Calls superclass method
# File lib/tumugi/plugin/task/bigquery_query.rb, line 22 def completed? if mode.to_sym == :append && !finished? false else super end end
output()
click to toggle source
# File lib/tumugi/plugin/task/bigquery_query.rb, line 18 def output @output ||= Tumugi::Plugin::BigqueryTableTarget.new(project_id: project_id, dataset_id: dataset_id, table_id: table_id) end
run()
click to toggle source
# File lib/tumugi/plugin/task/bigquery_query.rb, line 30 def run log "Launching Query" log "Query: #{query}" log "Query destination: #{output}" bq_client = output.client bq_client.query(query, project_id: project_id, dataset_id: output.dataset_id, table_id: output.table_id, mode: mode.to_sym, flatten_results: flatten_results, use_legacy_sql: use_legacy_sql, wait: wait) end