Class: Samidare::Embulk

Inherits:
Object
  • Object
show all
Defined in:
lib/samidare/embulk.rb

Instance Method Summary collapse

Instance Method Details

#run(database_configs, all_table_configs, bq_config, target_table_names = []) ⇒ Object 



3
4
5
6
7
8
9
10
11
12
13
14
 
# File 'lib/samidare/embulk.rb', line 3

def run(database_configs, all_table_configs, bq_config, target_table_names = [])
  error_tables = []
  database_configs.keys.each do |db_name|
    table_configs = target_table_configs(all_table_configs[db_name], target_table_names)
    error_tables = error_tables + run_by_database(
      db_name,
      table_configs,
      database_configs[db_name]['bq_dataset'],
      bq_config)
  end
  error_tables
end

#target_table_configs(table_configs, target_table_names) ⇒ Object 



16
17
18
19
 
# File 'lib/samidare/embulk.rb', line 16

def target_table_configs(table_configs, target_table_names)
  return table_configs if target_table_names.empty?
  table_configs.select { |table_config| target_table_names.include?(table_config.name) }
end