Method: Flydata::SourceMysql::PluginSupport::DmlRecordHandler#process

Defined in:
lib/flydata/source_mysql/plugin_support/dml_record_handler.rb

#process(record, type) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/flydata/source_mysql/plugin_support/dml_record_handler.rb', line 18

def process(record, type)
  case type
  when :write_rows
    emit_insert(record)
  when :delete_rows
    emit_delete(record)
  when :update_rows
    emit_update(record)
  else
    raise "Invalid type:#{type}"
  end
end