Module: RedshiftConnector

Defined in:
lib/redshift_connector/reader.rb,
lib/redshift_connector.rb,
lib/redshift_connector.rb,
lib/redshift_connector/query.rb,
lib/redshift_connector/logger.rb,
lib/redshift_connector/reader.rb,
lib/redshift_connector/version.rb,
lib/redshift_connector/exporter.rb,
lib/redshift_connector/importer.rb,
lib/redshift_connector/importer.rb,
lib/redshift_connector/connector.rb,
lib/redshift_connector/data_file.rb,
lib/redshift_connector/exception.rb,
lib/redshift_connector/s3_bucket.rb,
lib/redshift_connector/reader/csv.rb,
lib/redshift_connector/reader/tsv.rb,
lib/redshift_connector/s3_data_file.rb,
lib/redshift_connector/importer/upsert.rb,
lib/redshift_connector/reader/abstract.rb,
lib/redshift_connector/exporter_builder.rb,
lib/redshift_connector/reader/exception.rb,
lib/redshift_connector/immediate_exporter.rb,
lib/redshift_connector/redshift_data_type.rb,
lib/redshift_connector/reader/redshift_csv.rb,
lib/redshift_connector/s3_data_file_bundle.rb,
lib/redshift_connector/importer/insert_delta.rb,
lib/redshift_connector/active_record_exporter.rb,
lib/redshift_connector/data_file_bundle_params.rb,
lib/redshift_connector/data_file_bundle_reader.rb,
lib/redshift_connector/importer/rebuild_rename.rb,
lib/redshift_connector/active_record_data_source.rb,
lib/redshift_connector/importer/rebuild_truncate.rb

Overview

create module

Defined Under Namespace

Modules: Exporter, Importer, Reader, RedshiftDataType Classes: ActiveRecordDataSource, ActiveRecordExporter, ArbitraryQuery, Connector, DataFile, DataFileBundleParams, DataFileBundleReader, DeltaQuery, Error, ExportError, ExporterBuilder, ImmediateExporter, ImportError, NullLogger, S3Bucket, S3DataFile, S3DataFileBundle, SelectAllQuery, UnloadQuery

Constant Summary collapse

VERSION = 
'8.1.3'

Class Method Summary collapse

Class Method Details

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



32
33
34
 
# File 'lib/redshift_connector.rb', line 32

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

.get_reader_class(id) ⇒ Object 



15
16
17
 
# File 'lib/redshift_connector/reader/abstract.rb', line 15

def self.get_reader_class(id)
  Reader::Abstract.get_reader_class(id)
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 



20
21
22
 
# File 'lib/redshift_connector.rb', line 20

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

.transport_all_from_s3(**params) ⇒ Object 



28
29
30
 
# File 'lib/redshift_connector.rb', line 28

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

.transport_delta(**params) ⇒ Object 



16
17
18
 
# File 'lib/redshift_connector.rb', line 16

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

.transport_delta_from_s3(**params) ⇒ Object 



24
25
26
 
# File 'lib/redshift_connector.rb', line 24

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