Class: Linkage::SingleThreadedRunner

Inherits:

Runner

• Object
• Runner
• Linkage::SingleThreadedRunner

show all

Defined in:

lib/linkage/runner/single_threaded.rb

Instance Attribute Summary

Attributes inherited from Runner

#config

Instance Method Summary (collapse)

• - (Object) apply_expectations
• - (Object) execute
• - (Object) group_records
• - (Object) setup_datasets

Methods inherited from Runner

#initialize

14
15
16
17
18
19
20
21
22
23
24

# File 'lib/linkage/runner/single_threaded.rb', line 14

def apply_expectations
  @join_expectations = []
  @config.expectations.each do |exp|
    case exp.kind
    when :join
      @join_expectations << exp
      @dataset_1.add_select(exp.field_1)
      @dataset_1.add_order(exp.field_1)
    end
  end
end

3
4
5
6
7
8

# File 'lib/linkage/runner/single_threaded.rb', line 3

def execute
  create_groups_table
  setup_datasets
  apply_expectations
  group_records
end

26
27
28
29

# File 'lib/linkage/runner/single_threaded.rb', line 26

def group_records
  @dataset_1.each do |row|
  end
end

10
11
12

# File 'lib/linkage/runner/single_threaded.rb', line 10

def setup_datasets
  @dataset_1 = @config.dataset_1.clone
end