Module: RedshiftConnector

Defined in:
lib/redshift-connector/importer.rb,
lib/redshift-connector.rb,
lib/redshift-connector.rb,
lib/redshift-connector/query.rb,
lib/redshift-connector/logger.rb,
lib/redshift-connector/version.rb,
lib/redshift-connector/exporter.rb,
lib/redshift-connector/importer.rb,
lib/redshift-connector/connector.rb,
lib/redshift-connector/s3_bucket.rb,
lib/redshift-connector/s3_data_file.rb,
lib/redshift-connector/importer/upsert.rb,
lib/redshift-connector/s3_data_file_bundle.rb,
lib/redshift-connector/importer/insert_delta.rb,
lib/redshift-connector/importer/rebuild_rename.rb,
lib/redshift-connector/importer/rebuild_truncate.rb

Overview

create module

Defined Under Namespace

Modules: Importer Classes: ArbitraryQuery, Connector, DeltaQuery, Exporter, NullLogger, S3Bucket, S3DataFile, S3DataFileBundle, SelectAllQuery, UnloadQuery

Constant Summary collapse

VERSION = 
'6.0.0'

Class Method Summary collapse

Class Method Details

.foreach(**params, &block) ⇒ Object 



28
29
30
 
# File 'lib/redshift-connector.rb', line 28

def RedshiftConnector.foreach(**params, &block)
  Exporter.foreach(**params, &block)
end

.logger ⇒ Object 



4
5
6
7
 
# File 'lib/redshift-connector/logger.rb', line 4

def RedshiftConnector.logger
  # Defer to access Rails
  @logger || Rails.logger
end

.logger=(logger) ⇒ Object 



9
10
11
 
# File 'lib/redshift-connector/logger.rb', line 9

def RedshiftConnector.logger=(logger)
  @logger = logger
end

.transport_all(**params) ⇒ Object 



16
17
18
 
# File 'lib/redshift-connector.rb', line 16

def RedshiftConnector.transport_all(**params)
  Connector.transport_all(**params)
end

.transport_all_from_s3(**params) ⇒ Object 



24
25
26
 
# File 'lib/redshift-connector.rb', line 24

def RedshiftConnector.transport_all_from_s3(**params)
  Importer.transport_all_from_s3(**params)
end

.transport_delta(**params) ⇒ Object 



12
13
14
 
# File 'lib/redshift-connector.rb', line 12

def RedshiftConnector.transport_delta(**params)
  Connector.transport_delta(**params)
end

.transport_delta_from_s3(**params) ⇒ Object 



20
21
22
 
# File 'lib/redshift-connector.rb', line 20

def RedshiftConnector.transport_delta_from_s3(**params)
  Importer.transport_delta_from_s3(**params)
end