class RedshiftConnector::QueueryDataSource
Public Class Methods
new(client = nil)
click to toggle source
# File lib/redshift_connector/queuery_data_source.rb, line 8 def initialize(client = nil) @client = client || QueueryClient::Client.new end
Public Instance Methods
execute_query(stmt, params = [])
click to toggle source
# File lib/redshift_connector/queuery_data_source.rb, line 16 def execute_query(stmt, params = []) @client.query(stmt, params) rescue QueueryClient::QueryError => ex raise ExportError, ex.message end
exporter_builder()
click to toggle source
# File lib/redshift_connector/queuery_data_source.rb, line 12 def exporter_builder ExporterBuilder.new(ds: self, exporter_class: QueueryExporter) end