Package com.github.shyiko.mysql.binlog.event.deserialization

Class TableMapEventDataDeserializer

java.lang.Object

com.github.shyiko.mysql.binlog.event.deserialization.TableMapEventDataDeserializer

All Implemented Interfaces:

com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializer<com.github.shyiko.mysql.binlog.event.TableMapEventData>

public class TableMapEventDataDeserializer
extends Object
implements com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializer<com.github.shyiko.mysql.binlog.event.TableMapEventData>

Copied from mysql-binlog-connector 0.25.3 to support MYSQL_TYPE_TYPED_ARRAY.

Line 51 ~ 53: load column metadata bytes based on the length encoded before, instead of relying on readMetadata to parse it.

Line 93 ~ 98: process MYSQL_TYPE_TYPED_ARRAY metadata, imitated the code in canal TableMapLogEvent#decodeFields.

Remove this file once mysql-binlog-connector-java#104 fixed.

Constructor Summary

Constructors

Constructor	Description
TableMapEventDataDeserializer()

Method Summary

Modifier and Type	Method	Description
com.github.shyiko.mysql.binlog.event.TableMapEventData	deserialize(com.github.shyiko.mysql.binlog.io.ByteArrayInputStream inputStream)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TableMapEventDataDeserializer

public TableMapEventDataDeserializer()

Method Detail

deserialize

public com.github.shyiko.mysql.binlog.event.TableMapEventData deserialize(com.github.shyiko.mysql.binlog.io.ByteArrayInputStream inputStream)
                                                                   throws IOException

Specified by:

deserialize in interface com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializer<com.github.shyiko.mysql.binlog.event.TableMapEventData>

Throws:

IOException