Class: Flydata::SourceMysql::ParseDumpAndSend
- Inherits:
-
Flydata::Source::ParseDumpAndSend
- Object
- Flydata::Source::Component
- Flydata::Source::ParseDumpAndSend
- Flydata::SourceMysql::ParseDumpAndSend
- Defined in:
- lib/flydata/source_mysql/parse_dump_and_send.rb
Instance Method Summary collapse
- #parse_dump(dump_pos_info, dmpio, create_table_block, insert_record_block, check_point_source_pos_block) ⇒ Object
- #value_converters ⇒ Object
Methods inherited from Flydata::Source::ParseDumpAndSend
Methods inherited from Flydata::Source::Component
Constructor Details
This class inherits a constructor from Flydata::Source::Component
Instance Method Details
#parse_dump(dump_pos_info, dmpio, create_table_block, insert_record_block, check_point_source_pos_block) ⇒ Object
14 15 16 17 18 19 20 21 22 23 24 |
# File 'lib/flydata/source_mysql/parse_dump_and_send.rb', line 14 def parse_dump(dump_pos_info, dmpio, create_table_block, insert_record_block, check_point_source_pos_block) check_point_binlog_block = Proc.new { |source_table, last_pos, bytesize, binlog_hash, state, substate| source_pos = FlydataCore::Mysql::BinlogPos.new(binlog_hash) # SourcePos object is BinlogPos in SourceMysql check_point_source_pos_block.call(source_table, last_pos, bytesize, source_pos, state, substate) } Parser::MysqlDumpParser.new(dump_pos_info).parse(dmpio, create_table_block, insert_record_block, check_point_binlog_block) end |
#value_converters ⇒ Object
10 11 12 |
# File 'lib/flydata/source_mysql/parse_dump_and_send.rb', line 10 def value_converters FlydataCore::TableDef::MysqlTableDef::VALUE_CONVERTERS end |