Class: RailsRedshiftReplicator::Importers::IdentityReplicator

Inherits:
Base
  • Object
show all
Defined in:
lib/rails_redshift_replicator/importers/identity_replicator.rb

Instance Attribute Summary

Attributes inherited from Base

#replication

Instance Method Summary collapse

Methods inherited from Base

#copy, #copy_options, #copy_statement, #create_side_table, #create_temp_table, #drop_table, #evaluate_history_cap, #file_manager, #get_redshift_error, #import_file, #initialize, #merge_or_replace, #merge_statement, #notify_error, #replace_statement, #temporary_table_name

Constructor Details

This class inherits a constructor from RailsRedshiftReplicator::Importers::Base

Instance Method Details

#import ⇒ Object 



4
5
6
7
8
9
10
11
12
 
# File 'lib/rails_redshift_replicator/importers/identity_replicator.rb', line 4

def import
  import_start = replication.importing!
  copy replication.target_table, mark_as_imported: true
  return if replication.error?
  replication.clear_errors!
  replication.update_attributes import_duration: (Time.now-import_start).ceil
  evaluate_history_cap
  file_manager.delete if RailsRedshiftReplicator.delete_s3_file_after_import
end