Package org.apache.pulsar.io.canal

Class CanalByteSource

java.lang.Object

org.apache.pulsar.io.core.PushSource<V>

org.apache.pulsar.io.canal.CanalAbstractSource<byte[]>

org.apache.pulsar.io.canal.CanalByteSource

All Implemented Interfaces:

AutoCloseable, org.apache.pulsar.io.core.Source<byte[]>

public class CanalByteSource
extends CanalAbstractSource<byte[]>

A Simple class for mysql binlog sync to pulsar.

Field Summary

Fields inherited from class org.apache.pulsar.io.canal.CanalAbstractSource

handler, running, thread

Constructor Summary

Constructors

Constructor	Description
CanalByteSource()

Method Summary

Modifier and Type	Method	Description
byte[]	extractValue(List<com.alibaba.otter.canal.protocol.FlatMessage> flatMessages)
Long	getMessageId(com.alibaba.otter.canal.protocol.Message message)

Methods inherited from class org.apache.pulsar.io.canal.CanalAbstractSource

close, open, process, start

Methods inherited from class org.apache.pulsar.io.core.PushSource

consume, getQueueLength, read

Methods inherited from class java.lang.Object

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

Constructor Details

CanalByteSource

public CanalByteSource()

Method Details

getMessageId

public Long getMessageId(com.alibaba.otter.canal.protocol.Message message)

Specified by:

getMessageId in class CanalAbstractSource<byte[]>

extractValue

public byte[] extractValue(List<com.alibaba.otter.canal.protocol.FlatMessage> flatMessages)

Specified by:

extractValue in class CanalAbstractSource<byte[]>