com.alibaba.otter.canal.instance.manager

类 CanalInstanceWithManager

java.lang.Object

com.alibaba.otter.canal.common.AbstractCanalLifeCycle

com.alibaba.otter.canal.instance.core.AbstractCanalInstance

com.alibaba.otter.canal.instance.manager.CanalInstanceWithManager

所有已实现的接口:

com.alibaba.otter.canal.common.CanalLifeCycle, CanalInstance

public class CanalInstanceWithManager
extends AbstractCanalInstance

单个canal实例，比如一个destination会独立一个实例

版本:

1.0.0

作者:

jianghang 2012-7-11 下午09:26:51

字段概要

字段

限定符和类型	字段和说明
protected java.lang.String	filter
protected CanalParameter	parameters

从类继承的字段 com.alibaba.otter.canal.instance.core.AbstractCanalInstance

alarmHandler, canalId, destination, eventParser, eventSink, eventStore, metaManager, mqConfig

从类继承的字段 com.alibaba.otter.canal.common.AbstractCanalLifeCycle

running

构造器概要

构造器

构造器和说明
CanalInstanceWithManager(Canal canal, java.lang.String filter)

方法概要

限定符和类型	方法和说明
protected void	initAlarmHandler()
protected void	initEventParser()
protected void	initEventSink()
protected void	initEventStore()
protected com.alibaba.otter.canal.parse.ha.CanalHAController	initHaController()
protected com.alibaba.otter.canal.parse.index.CanalLogPositionManager	initLogPositionManager()
protected void	initMetaManager()
void	setAlarmHandler(com.alibaba.otter.canal.common.alarm.CanalAlarmHandler alarmHandler)
void	start()
protected void	startEventParserInternal(com.alibaba.otter.canal.parse.CanalEventParser eventParser, boolean isGroup)

从类继承的方法 com.alibaba.otter.canal.instance.core.AbstractCanalInstance

afterStartEventParser, afterStopEventParser, beforeStartEventParser, beforeStopEventParser, getAlarmHandler, getDestination, getEventParser, getEventSink, getEventStore, getMetaManager, getMqConfig, stop, stopEventParserInternal, subscribeChange

从类继承的方法 com.alibaba.otter.canal.common.AbstractCanalLifeCycle

isStart

从类继承的方法 java.lang.Object

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

从接口继承的方法 com.alibaba.otter.canal.common.CanalLifeCycle

isStart

字段详细资料

filter

protected java.lang.String filter

parameters

protected CanalParameter parameters

构造器详细资料

CanalInstanceWithManager

public CanalInstanceWithManager(Canal canal,
                                java.lang.String filter)

方法详细资料

start

public void start()

指定者:

start 在接口中 com.alibaba.otter.canal.common.CanalLifeCycle

覆盖:

start 在类中 AbstractCanalInstance

initAlarmHandler

protected void initAlarmHandler()

initMetaManager

protected void initMetaManager()

initEventStore

protected void initEventStore()

initEventSink

protected void initEventSink()

initEventParser

protected void initEventParser()

initHaController

protected com.alibaba.otter.canal.parse.ha.CanalHAController initHaController()

initLogPositionManager

protected com.alibaba.otter.canal.parse.index.CanalLogPositionManager initLogPositionManager()

startEventParserInternal

protected void startEventParserInternal(com.alibaba.otter.canal.parse.CanalEventParser eventParser,
                                        boolean isGroup)

覆盖:

startEventParserInternal 在类中 AbstractCanalInstance

setAlarmHandler

public void setAlarmHandler(com.alibaba.otter.canal.common.alarm.CanalAlarmHandler alarmHandler)