Method: Taps::Push#push_partial_data

Defined in:
lib/taps/operation.rb

#push_partial_data ⇒ Object 



455
456
457
458
459
460
461
462
463
464
 
# File 'lib/taps/operation.rb', line 455

def push_partial_data
  return if stream_state == {}

  table_name = stream_state[:table_name]
  record_count = tables[table_name.to_s]
  puts "Resuming #{table_name}, #{format_number(record_count)} records"
  progress = ProgressBar.new(table_name.to_s, record_count)
  stream = Taps::DataStream.factory(db, stream_state)
  push_data_from_table(stream, progress)
end