Class: Ductr::ETL::KibaRunner

Inherits:

Runner

• Object
• Runner
• Ductr::ETL::KibaRunner

Extended by:

Forwardable

Defined in:

lib/ductr/etl/kiba_runner.rb

Overview

A runner based on kiba’s streaming runner

See Also:

• streaming runner source code to get details about its forwarded methods

Instance Attribute Summary

Attributes inherited from Runner

#destinations, #pipes, #sources, #transforms

Instance Method Summary

• #run ⇒ void

  Calls kiba’s streaming runner #process_rows and #close_destinations like Kiba::StreamingRunner#run.

Methods inherited from Runner

#initialize

Constructor Details

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

Instance Method Details

#run ⇒ void

This method returns an undefined value.

Calls kiba’s streaming runner #process_rows and #close_destinations like Kiba::StreamingRunner#run

# File 'lib/ductr/etl/kiba_runner.rb', line 20

def run
  process_rows(sources, transforms, destinations)
  close_destinations(destinations)
end