Class: Ductr::ETL::Runner

Inherits:
Object
  • Object
show all
Defined in:
lib/ductr/etl/runner.rb

Overview

The base class for all runners

Direct Known Subclasses

FiberRunner, KibaRunner

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(sources, transforms, destinations, pipes = []) ⇒ Runner

Creates the runner instance.

Parameters:

  • sources (Array<Source>) —

    The job’s source controls

  • transforms (Array<Transform>) —

    The job’s transform controls

  • destinations (Array<Destination>) —

    The job’s destination controls

  • pipes (Array<Hash{Symbol => Array<Symbol>}>) (defaults to: []) —

    The controls plumbing hashes



29
30
31
32
33
34
 
# File 'lib/ductr/etl/runner.rb', line 29

def initialize(sources, transforms, destinations, pipes = [])
  @sources = sources
  @transforms = transforms
  @destinations = destinations
  @pipes = pipes
end

Instance Attribute Details

#destinations ⇒ Array<Destination>

Returns The runner destination controls.

Returns:

  • (Array<Destination>) —

    The runner destination controls



16
17
18
 
# File 'lib/ductr/etl/runner.rb', line 16

def destinations
  @destinations
end

#pipes ⇒ Array<Hash{Symbol => Array<Symbol>}>

Returns The controls plumbing hashes.

Returns:

  • (Array<Hash{Symbol => Array<Symbol>}>) —

    The controls plumbing hashes



19
20
21
 
# File 'lib/ductr/etl/runner.rb', line 19

def pipes
  @pipes
end

#sources ⇒ Array<Source>

Returns The runner source controls.

Returns:

  • (Array<Source>) —

    The runner source controls



10
11
12
 
# File 'lib/ductr/etl/runner.rb', line 10

def sources
  @sources
end

#transforms ⇒ Array<Transform>

Returns The runner transform controls.

Returns:

  • (Array<Transform>) —

    The runner transform controls



13
14
15
 
# File 'lib/ductr/etl/runner.rb', line 13

def transforms
  @transforms
end