com.alibaba.otter.canal.instance.manager.model

类 CanalParameter

java.lang.Object

com.alibaba.otter.canal.instance.manager.model.CanalParameter

所有已实现的接口:

java.io.Serializable

public class CanalParameter
extends java.lang.Object
implements java.io.Serializable

canal运行相关参数

版本:

1.0.0

作者:

jianghang 2012-7-4 下午02:52:52

另请参阅:

序列化表格

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	CanalParameter.BatchMode
static class	CanalParameter.ClusterMode
static class	CanalParameter.DataSourcing 数据来源描述
static class	CanalParameter.HAMode
static class	CanalParameter.IndexMode
static class	CanalParameter.MetaMode
static class	CanalParameter.RunMode
static class	CanalParameter.SourcingType
static class	CanalParameter.StorageMode
static class	CanalParameter.StorageScavengeMode

构造器概要

构造器

构造器和说明
CanalParameter()

方法概要

限定符和类型	方法和说明
java.lang.String	getAlarmHandlerClass()
java.lang.String	getAlarmHandlerPluginDir()
java.lang.String	getApp()
java.lang.String	getBlackFilter()
java.lang.Long	getCanalId()
CanalParameter.ClusterMode	getClusterMode()
java.lang.String	getConnectionCharset()
java.lang.Byte	getConnectionCharsetNumber()
java.lang.String	getDataDir()
java.util.List<java.net.InetSocketAddress>	getDbAddresses()
java.lang.String	getDbPassword()
java.lang.String	getDbUsername()
java.lang.Boolean	getDdlIsolation()
java.lang.Integer	getDefaultConnectionTimeoutInSeconds()
java.lang.String	getDefaultDatabaseName()
java.lang.Boolean	getDetectingEnable()
java.lang.Integer	getDetectingIntervalInSeconds()
java.lang.Integer	getDetectingRetryTimes()
java.lang.String	getDetectingSQL()
java.lang.Integer	getDetectingTimeoutThresholdInSeconds()
java.lang.Integer	getFallbackIntervalInSeconds()
java.lang.String	getFileStorageDirectory()
java.lang.Integer	getFileStoragePercentThresold()
java.lang.Integer	getFileStorageRollverCount()
java.lang.Integer	getFileStorageStoreCount()
java.lang.Boolean	getFilterTableError()
java.lang.String	getGroup()
java.util.List<java.util.List<CanalParameter.DataSourcing>>	getGroupDbAddresses()
java.lang.Boolean	getGtidEnable()
CanalParameter.HAMode	getHaMode()
java.lang.Boolean	getHeartbeatHaEnable()
CanalParameter.IndexMode	getIndexMode()
java.lang.String	getLocalBinlogDirectory()
java.lang.String	getMediaGroup()
java.lang.Integer	getMemoryStorageBufferMemUnit()
java.lang.Integer	getMemoryStorageBufferSize()
java.lang.Boolean	getMemoryStorageRawEntry()
java.lang.Integer	getMetaFileFlushPeriod()
CanalParameter.MetaMode	getMetaMode()
java.lang.String	getMetaqStoreUri()
java.lang.Boolean	getParallel()
java.lang.Integer	getPort()
java.util.List<java.lang.String>	getPositions()
java.lang.String	getRdsAccesskey()
java.lang.String	getRdsInstanceId()
java.lang.String	getRdsSecretkey()
java.lang.Integer	getReceiveBufferSize()
CanalParameter.RunMode	getRunMode()
java.lang.String	getScavengeSchdule()
java.lang.Integer	getSendBufferSize()
java.lang.Long	getSlaveId()
CanalParameter.SourcingType	getSourcingType()
CanalParameter.BatchMode	getStorageBatchMode()
CanalParameter.StorageMode	getStorageMode()
CanalParameter.StorageScavengeMode	getStorageScavengeMode()
java.lang.Integer	getTransactionSize()
java.lang.Boolean	getTsdbEnable()
java.lang.String	getTsdbJdbcPassword()
java.lang.String	getTsdbJdbcUrl()
java.lang.String	getTsdbJdbcUserName()
java.lang.Integer	getTsdbSnapshotExpire()
java.lang.Integer	getTsdbSnapshotInterval()
java.lang.Long	getZkClusterId()
java.util.List<java.lang.String>	getZkClusters()
void	setAlarmHandlerClass(java.lang.String alarmHandlerClass)
void	setAlarmHandlerPluginDir(java.lang.String alarmHandlerPluginDir)
void	setApp(java.lang.String app)
void	setBlackFilter(java.lang.String blackFilter)
void	setCanalId(java.lang.Long canalId)
void	setClusterMode(CanalParameter.ClusterMode clusterMode)
void	setConnectionCharset(java.lang.String connectionCharset)
void	setConnectionCharsetNumber(java.lang.Byte connectionCharsetNumber)
void	setDataDir(java.lang.String dataDir)
void	setDbAddresses(java.util.List<java.net.InetSocketAddress> dbAddresses)
void	setDbPassword(java.lang.String dbPassword)
void	setDbUsername(java.lang.String dbUsername)
void	setDdlIsolation(java.lang.Boolean ddlIsolation)
void	setDefaultConnectionTimeoutInSeconds(java.lang.Integer defaultConnectionTimeoutInSeconds)
void	setDefaultDatabaseName(java.lang.String defaultDatabaseName)
void	setDetectingEnable(java.lang.Boolean detectingEnable)
void	setDetectingIntervalInSeconds(java.lang.Integer detectingIntervalInSeconds)
void	setDetectingRetryTimes(java.lang.Integer detectingRetryTimes)
void	setDetectingSQL(java.lang.String detectingSQL)
void	setDetectingTimeoutThresholdInSeconds(java.lang.Integer detectingTimeoutThresholdInSeconds)
void	setFallbackIntervalInSeconds(java.lang.Integer fallbackIntervalInSeconds)
void	setFileStorageDirectory(java.lang.String fileStorageDirectory)
void	setFileStoragePercentThresold(java.lang.Integer fileStoragePercentThresold)
void	setFileStorageRollverCount(java.lang.Integer fileStorageRollverCount)
void	setFileStorageStoreCount(java.lang.Integer fileStorageStoreCount)
void	setFilterTableError(java.lang.Boolean filterTableError)
void	setGroup(java.lang.String group)
void	setGroupDbAddresses(java.util.List<java.util.List<CanalParameter.DataSourcing>> groupDbAddresses)
void	setGtidEnable(java.lang.Boolean gtidEnable)
void	setHaMode(CanalParameter.HAMode haMode)
void	setHeartbeatHaEnable(java.lang.Boolean heartbeatHaEnable)
void	setIndexMode(CanalParameter.IndexMode indexMode)
void	setLocalBinlogDirectory(java.lang.String localBinlogDirectory)
void	setMasterAddress(java.net.InetSocketAddress masterAddress)
void	setMasterLogfileName(java.lang.String masterLogfileName)
void	setMasterLogfileOffest(java.lang.Long masterLogfileOffest)
void	setMasterPassword(java.lang.String masterPassword)
void	setMasterTimestamp(java.lang.Long masterTimestamp)
void	setMasterUsername(java.lang.String masterUsername)
void	setMediaGroup(java.lang.String mediaGroup)
void	setMemoryStorageBufferMemUnit(java.lang.Integer memoryStorageBufferMemUnit)
void	setMemoryStorageBufferSize(java.lang.Integer memoryStorageBufferSize)
void	setMemoryStorageRawEntry(java.lang.Boolean memoryStorageRawEntry)
void	setMetaFileFlushPeriod(java.lang.Integer metaFileFlushPeriod)
void	setMetaMode(CanalParameter.MetaMode metaMode)
void	setMetaqStoreUri(java.lang.String metaqStoreUri)
void	setParallel(java.lang.Boolean parallel)
void	setPort(java.lang.Integer port)
void	setPositions(java.util.List<java.lang.String> positions)
void	setRdsAccesskey(java.lang.String rdsAccesskey)
void	setRdsInstanceId(java.lang.String rdsInstanceId)
void	setRdsSecretkey(java.lang.String rdsSecretkey)
void	setReceiveBufferSize(java.lang.Integer receiveBufferSize)
void	setRunMode(CanalParameter.RunMode runMode)
void	setScavengeSchdule(java.lang.String scavengeSchdule)
void	setSendBufferSize(java.lang.Integer sendBufferSize)
void	setSlaveId(java.lang.Long slaveId)
void	setSourcingType(CanalParameter.SourcingType sourcingType)
void	setStandbyAddress(java.net.InetSocketAddress standbyAddress)
void	setStandbyLogfileName(java.lang.String standbyLogfileName)
void	setStandbyLogfileOffest(java.lang.Long standbyLogfileOffest)
void	setStandbyPassword(java.lang.String standbyPassword)
void	setStandbyTimestamp(java.lang.Long standbyTimestamp)
void	setStandbyUsername(java.lang.String standbyUsername)
void	setStorageBatchMode(CanalParameter.BatchMode storageBatchMode)
void	setStorageMode(CanalParameter.StorageMode storageMode)
void	setStorageScavengeMode(CanalParameter.StorageScavengeMode storageScavengeMode)
void	setTransactionSize(java.lang.Integer transactionSize)
void	setTsdbEnable(java.lang.Boolean tsdbEnable)
void	setTsdbJdbcPassword(java.lang.String tsdbJdbcPassword)
void	setTsdbJdbcUrl(java.lang.String tsdbJdbcUrl)
void	setTsdbJdbcUserName(java.lang.String tsdbJdbcUserName)
void	setTsdbSnapshotExpire(java.lang.Integer tsdbSnapshotExpire)
void	setTsdbSnapshotInterval(java.lang.Integer tsdbSnapshotInterval)
void	setZkClusterId(java.lang.Long zkClusterId)
void	setZkClusters(java.util.List<java.lang.String> zkClusters)
java.lang.String	toString()

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

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

构造器详细资料

CanalParameter

public CanalParameter()

方法详细资料

getCanalId

public java.lang.Long getCanalId()

setCanalId

public void setCanalId(java.lang.Long canalId)

getRunMode

public CanalParameter.RunMode getRunMode()

setRunMode

public void setRunMode(CanalParameter.RunMode runMode)

getClusterMode

public CanalParameter.ClusterMode getClusterMode()

setClusterMode

public void setClusterMode(CanalParameter.ClusterMode clusterMode)

getZkClusters

public java.util.List<java.lang.String> getZkClusters()

setZkClusters

public void setZkClusters(java.util.List<java.lang.String> zkClusters)

getMetaMode

public CanalParameter.MetaMode getMetaMode()

setMetaMode

public void setMetaMode(CanalParameter.MetaMode metaMode)

getStorageMode

public CanalParameter.StorageMode getStorageMode()

getDataDir

public java.lang.String getDataDir()

setDataDir

public void setDataDir(java.lang.String dataDir)

getMetaFileFlushPeriod

public java.lang.Integer getMetaFileFlushPeriod()

setMetaFileFlushPeriod

public void setMetaFileFlushPeriod(java.lang.Integer metaFileFlushPeriod)

setStorageMode

public void setStorageMode(CanalParameter.StorageMode storageMode)

getMemoryStorageBufferSize

public java.lang.Integer getMemoryStorageBufferSize()

setMemoryStorageBufferSize

public void setMemoryStorageBufferSize(java.lang.Integer memoryStorageBufferSize)

getFileStorageDirectory

public java.lang.String getFileStorageDirectory()

setFileStorageDirectory

public void setFileStorageDirectory(java.lang.String fileStorageDirectory)

getFileStorageStoreCount

public java.lang.Integer getFileStorageStoreCount()

setFileStorageStoreCount

public void setFileStorageStoreCount(java.lang.Integer fileStorageStoreCount)

getFileStorageRollverCount

public java.lang.Integer getFileStorageRollverCount()

setFileStorageRollverCount

public void setFileStorageRollverCount(java.lang.Integer fileStorageRollverCount)

getFileStoragePercentThresold

public java.lang.Integer getFileStoragePercentThresold()

setFileStoragePercentThresold

public void setFileStoragePercentThresold(java.lang.Integer fileStoragePercentThresold)

getSourcingType

public CanalParameter.SourcingType getSourcingType()

setSourcingType

public void setSourcingType(CanalParameter.SourcingType sourcingType)

getLocalBinlogDirectory

public java.lang.String getLocalBinlogDirectory()

setLocalBinlogDirectory

public void setLocalBinlogDirectory(java.lang.String localBinlogDirectory)

getHaMode

public CanalParameter.HAMode getHaMode()

setHaMode

public void setHaMode(CanalParameter.HAMode haMode)

getPort

public java.lang.Integer getPort()

setPort

public void setPort(java.lang.Integer port)

getDefaultConnectionTimeoutInSeconds

public java.lang.Integer getDefaultConnectionTimeoutInSeconds()

setDefaultConnectionTimeoutInSeconds

public void setDefaultConnectionTimeoutInSeconds(java.lang.Integer defaultConnectionTimeoutInSeconds)

getReceiveBufferSize

public java.lang.Integer getReceiveBufferSize()

setReceiveBufferSize

public void setReceiveBufferSize(java.lang.Integer receiveBufferSize)

getSendBufferSize

public java.lang.Integer getSendBufferSize()

setSendBufferSize

public void setSendBufferSize(java.lang.Integer sendBufferSize)

getConnectionCharsetNumber

public java.lang.Byte getConnectionCharsetNumber()

setConnectionCharsetNumber

public void setConnectionCharsetNumber(java.lang.Byte connectionCharsetNumber)

getConnectionCharset

public java.lang.String getConnectionCharset()

setConnectionCharset

public void setConnectionCharset(java.lang.String connectionCharset)

getIndexMode

public CanalParameter.IndexMode getIndexMode()

setIndexMode

public void setIndexMode(CanalParameter.IndexMode indexMode)

getDefaultDatabaseName

public java.lang.String getDefaultDatabaseName()

setDefaultDatabaseName

public void setDefaultDatabaseName(java.lang.String defaultDatabaseName)

getSlaveId

public java.lang.Long getSlaveId()

setSlaveId

public void setSlaveId(java.lang.Long slaveId)

getDetectingEnable

public java.lang.Boolean getDetectingEnable()

setDetectingEnable

public void setDetectingEnable(java.lang.Boolean detectingEnable)

getDetectingSQL

public java.lang.String getDetectingSQL()

setDetectingSQL

public void setDetectingSQL(java.lang.String detectingSQL)

getDetectingIntervalInSeconds

public java.lang.Integer getDetectingIntervalInSeconds()

setDetectingIntervalInSeconds

public void setDetectingIntervalInSeconds(java.lang.Integer detectingIntervalInSeconds)

getDetectingTimeoutThresholdInSeconds

public java.lang.Integer getDetectingTimeoutThresholdInSeconds()

setDetectingTimeoutThresholdInSeconds

public void setDetectingTimeoutThresholdInSeconds(java.lang.Integer detectingTimeoutThresholdInSeconds)

getDetectingRetryTimes

public java.lang.Integer getDetectingRetryTimes()

setDetectingRetryTimes

public void setDetectingRetryTimes(java.lang.Integer detectingRetryTimes)

getStorageScavengeMode

public CanalParameter.StorageScavengeMode getStorageScavengeMode()

setStorageScavengeMode

public void setStorageScavengeMode(CanalParameter.StorageScavengeMode storageScavengeMode)

getScavengeSchdule

public java.lang.String getScavengeSchdule()

setScavengeSchdule

public void setScavengeSchdule(java.lang.String scavengeSchdule)

getApp

public java.lang.String getApp()

getGroup

public java.lang.String getGroup()

setApp

public void setApp(java.lang.String app)

setGroup

public void setGroup(java.lang.String group)

getMetaqStoreUri

public java.lang.String getMetaqStoreUri()

setMetaqStoreUri

public void setMetaqStoreUri(java.lang.String metaqStoreUri)

getTransactionSize

public java.lang.Integer getTransactionSize()

setTransactionSize

public void setTransactionSize(java.lang.Integer transactionSize)

getDbAddresses

public java.util.List<java.net.InetSocketAddress> getDbAddresses()

getGroupDbAddresses

public java.util.List<java.util.List<CanalParameter.DataSourcing>> getGroupDbAddresses()

setGroupDbAddresses

public void setGroupDbAddresses(java.util.List<java.util.List<CanalParameter.DataSourcing>> groupDbAddresses)

setDbAddresses

public void setDbAddresses(java.util.List<java.net.InetSocketAddress> dbAddresses)

getDbUsername

public java.lang.String getDbUsername()

setDbUsername

public void setDbUsername(java.lang.String dbUsername)

getDbPassword

public java.lang.String getDbPassword()

setDbPassword

public void setDbPassword(java.lang.String dbPassword)

getPositions

public java.util.List<java.lang.String> getPositions()

setPositions

public void setPositions(java.util.List<java.lang.String> positions)

setMasterUsername

public void setMasterUsername(java.lang.String masterUsername)

setMasterPassword

public void setMasterPassword(java.lang.String masterPassword)

setStandbyAddress

public void setStandbyAddress(java.net.InetSocketAddress standbyAddress)

setStandbyUsername

public void setStandbyUsername(java.lang.String standbyUsername)

setStandbyPassword

public void setStandbyPassword(java.lang.String standbyPassword)

setMasterLogfileName

public void setMasterLogfileName(java.lang.String masterLogfileName)

setMasterLogfileOffest

public void setMasterLogfileOffest(java.lang.Long masterLogfileOffest)

setMasterTimestamp

public void setMasterTimestamp(java.lang.Long masterTimestamp)

setStandbyLogfileName

public void setStandbyLogfileName(java.lang.String standbyLogfileName)

setStandbyLogfileOffest

public void setStandbyLogfileOffest(java.lang.Long standbyLogfileOffest)

setStandbyTimestamp

public void setStandbyTimestamp(java.lang.Long standbyTimestamp)

setMasterAddress

public void setMasterAddress(java.net.InetSocketAddress masterAddress)

getFallbackIntervalInSeconds

public java.lang.Integer getFallbackIntervalInSeconds()

setFallbackIntervalInSeconds

public void setFallbackIntervalInSeconds(java.lang.Integer fallbackIntervalInSeconds)

getHeartbeatHaEnable

public java.lang.Boolean getHeartbeatHaEnable()

setHeartbeatHaEnable

public void setHeartbeatHaEnable(java.lang.Boolean heartbeatHaEnable)

getStorageBatchMode

public CanalParameter.BatchMode getStorageBatchMode()

setStorageBatchMode

public void setStorageBatchMode(CanalParameter.BatchMode storageBatchMode)

getMemoryStorageBufferMemUnit

public java.lang.Integer getMemoryStorageBufferMemUnit()

setMemoryStorageBufferMemUnit

public void setMemoryStorageBufferMemUnit(java.lang.Integer memoryStorageBufferMemUnit)

getMediaGroup

public java.lang.String getMediaGroup()

setMediaGroup

public void setMediaGroup(java.lang.String mediaGroup)

getZkClusterId

public java.lang.Long getZkClusterId()

setZkClusterId

public void setZkClusterId(java.lang.Long zkClusterId)

getDdlIsolation

public java.lang.Boolean getDdlIsolation()

setDdlIsolation

public void setDdlIsolation(java.lang.Boolean ddlIsolation)

getFilterTableError

public java.lang.Boolean getFilterTableError()

setFilterTableError

public void setFilterTableError(java.lang.Boolean filterTableError)

getBlackFilter

public java.lang.String getBlackFilter()

setBlackFilter

public void setBlackFilter(java.lang.String blackFilter)

getTsdbEnable

public java.lang.Boolean getTsdbEnable()

setTsdbEnable

public void setTsdbEnable(java.lang.Boolean tsdbEnable)

getTsdbJdbcUrl

public java.lang.String getTsdbJdbcUrl()

setTsdbJdbcUrl

public void setTsdbJdbcUrl(java.lang.String tsdbJdbcUrl)

getTsdbJdbcUserName

public java.lang.String getTsdbJdbcUserName()

setTsdbJdbcUserName

public void setTsdbJdbcUserName(java.lang.String tsdbJdbcUserName)

getTsdbJdbcPassword

public java.lang.String getTsdbJdbcPassword()

setTsdbJdbcPassword

public void setTsdbJdbcPassword(java.lang.String tsdbJdbcPassword)

getRdsAccesskey

public java.lang.String getRdsAccesskey()

setRdsAccesskey

public void setRdsAccesskey(java.lang.String rdsAccesskey)

getRdsSecretkey

public java.lang.String getRdsSecretkey()

setRdsSecretkey

public void setRdsSecretkey(java.lang.String rdsSecretkey)

getRdsInstanceId

public java.lang.String getRdsInstanceId()

setRdsInstanceId

public void setRdsInstanceId(java.lang.String rdsInstanceId)

getGtidEnable

public java.lang.Boolean getGtidEnable()

setGtidEnable

public void setGtidEnable(java.lang.Boolean gtidEnable)

getMemoryStorageRawEntry

public java.lang.Boolean getMemoryStorageRawEntry()

setMemoryStorageRawEntry

public void setMemoryStorageRawEntry(java.lang.Boolean memoryStorageRawEntry)

getTsdbSnapshotInterval

public java.lang.Integer getTsdbSnapshotInterval()

setTsdbSnapshotInterval

public void setTsdbSnapshotInterval(java.lang.Integer tsdbSnapshotInterval)

getTsdbSnapshotExpire

public java.lang.Integer getTsdbSnapshotExpire()

setTsdbSnapshotExpire

public void setTsdbSnapshotExpire(java.lang.Integer tsdbSnapshotExpire)

getParallel

public java.lang.Boolean getParallel()

setParallel

public void setParallel(java.lang.Boolean parallel)

getAlarmHandlerClass

public java.lang.String getAlarmHandlerClass()

setAlarmHandlerClass

public void setAlarmHandlerClass(java.lang.String alarmHandlerClass)

getAlarmHandlerPluginDir

public java.lang.String getAlarmHandlerPluginDir()

setAlarmHandlerPluginDir

public void setAlarmHandlerPluginDir(java.lang.String alarmHandlerPluginDir)

toString

public java.lang.String toString()

覆盖:

toString 在类中 java.lang.Object