Class: Ductr::SequelBase::BufferedUpsertDestination

Inherits:

ETL::BufferedDestination

• Object
• ETL::Control
• ETL::Destination
• ETL::BufferedDestination
• Ductr::SequelBase::BufferedUpsertDestination

Defined in:

lib/ductr/sequel_base/buffered_upsert_destination.rb

Overview

A destination control that accumulates rows in a buffer to upsert them by batch.

Instance Attribute Summary

Attributes inherited from ETL::BufferedDestination

#buffer

Attributes inherited from ETL::Control

#adapter, #job_method, #options

Instance Method Summary

• #on_flush ⇒ void

  Open the database if needed and call the job’s method to run the query.

Methods inherited from ETL::BufferedDestination

#buffer_size, #close, #flush_buffer, #write

Methods inherited from ETL::Destination

#close, #write

Methods inherited from ETL::Control

#call_method, #initialize

Constructor Details

This class inherits a constructor from Ductr::ETL::Control

Instance Method Details

#on_flush ⇒ void

This method returns an undefined value.

Open the database if needed and call the job’s method to run the query.

# File 'lib/ductr/sequel_base/buffered_upsert_destination.rb', line 14

def on_flush
  call_method(adapter.db, excluded, buffer)
end