Package org.apache.pulsar.io.canal

Class CanalAbstractSource<V>

java.lang.Object

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

org.apache.pulsar.io.canal.CanalAbstractSource<V>

All Implemented Interfaces:

AutoCloseable, Source<V>

Direct Known Subclasses:

CanalByteSource, CanalStringSource

public abstract class CanalAbstractSource<V>
extends PushSource<V>

A Simple abstract class for mysql binlog sync to pulsar.

Field Summary

Fields

Modifier and Type	Field	Description
protected final Thread.UncaughtExceptionHandler	handler
protected boolean	running
protected Thread	thread

Constructor Summary

Constructors

Constructor	Description
CanalAbstractSource()

Method Summary

Modifier and Type	Method	Description
void	close()
abstract V	extractValue(List<com.alibaba.otter.canal.protocol.FlatMessage> flatMessages)
abstract Long	getMessageId(com.alibaba.otter.canal.protocol.Message message)
void	open(Map<String,Object> config, SourceContext sourceContext)
protected void	process()
protected void	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

Field Details

thread

protected Thread thread

running

protected volatile boolean running

handler

protected final Thread.UncaughtExceptionHandler handler

Constructor Details

CanalAbstractSource

public CanalAbstractSource()

Method Details

open

public void open(Map<String,Object> config,
 SourceContext sourceContext)
          throws Exception

Specified by:

open in interface Source<V>

Specified by:

open in class PushSource<V>

Throws:

Exception

start

protected void start()

close

public void close()
           throws InterruptedException

Throws:

InterruptedException

process

protected void process()

getMessageId

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

extractValue

public abstract V extractValue(List<com.alibaba.otter.canal.protocol.FlatMessage> flatMessages)