Package org.apache.pulsar.io.canal

Class MessageUtils

java.lang.Object

org.apache.pulsar.io.canal.MessageUtils

public class MessageUtils
extends Object

A Simple class for mysql binlog message to parse.

Constructor Summary

Constructors

Constructor	Description
MessageUtils()

Method Summary

Modifier and Type	Method	Description
static Map<String,String>	genColumn(com.alibaba.otter.canal.protocol.CanalEntry.Column column)
static List<com.alibaba.otter.canal.protocol.FlatMessage>	messageConverter(com.alibaba.otter.canal.protocol.Message message)	Message convert to FlatMessage.

Methods inherited from class java.lang.Object

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

Constructor Details

MessageUtils

public MessageUtils()

Method Details

genColumn

public static Map<String,String> genColumn(com.alibaba.otter.canal.protocol.CanalEntry.Column column)

messageConverter

public static List<com.alibaba.otter.canal.protocol.FlatMessage> messageConverter(com.alibaba.otter.canal.protocol.Message message)

Message convert to FlatMessage.

Parameters:

message -

Returns:

FlatMessage List