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/version.rb,
lib/redshift_connector/exporter.rb,
lib/redshift_connector/importer.rb,
lib/redshift_connector/connector.rb,
lib/redshift_connector/exception.rb,
lib/redshift_connector/importer/upsert.rb,
lib/redshift_connector/exporter_builder.rb,
lib/redshift_connector/immediate_exporter.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/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 Classes: ActiveRecordDataSource, ActiveRecordExporter, ArbitraryQuery, Connector, DataFileBundleParams, DeltaQuery, Error, ExportError, ExporterBuilder, ImmediateExporter, ImportError, SelectAllQuery, UnloadQuery

Constant Summary collapse

VERSION = 
'7.2.2'

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

.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