Class: Samidare::EmbulkClient

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

Instance Method Summary collapse

Instance Method Details

#generate_config(bq_config) ⇒ Object 



8
9
10
 
# File 'lib/samidare.rb', line 8

def generate_config(bq_config)
  Samidare::EmbulkUtility::ConfigGenerator.new.generate_config(database_configs, bq_config)
end

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



12
13
14
15
16
17
18
19
20
 
# File 'lib/samidare.rb', line 12

def run(bq_config, target_table_names = [])
  error_tables = Samidare::Embulk.new.run(
    database_configs,
    Samidare::MySQL::TableConfig.generate_table_configs,
    bq_config,
    target_table_names)
  # return batch status(true: all tables success)

  error_tables.size == 0
end