chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

CanalParameter类添加parallel参数

Browse Source
This commit is contained in:
zhikuodai
2019-02-21 22:04:06 +08:00
parent 1de8b27da1
commit a68bd28852
2 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java
View File

@@ -59,7 +59,7 @@ import com.alibaba.otter.canal.store.model.BatchMode;
/** /**
* 单个canal实例，比如一个destination会独立一个实例 * 单个canal实例，比如一个destination会独立一个实例
* *
* @author jianghang 2012-7-11 下午09:26:51 * @author jianghang 2012-7-11 下午09:26:51
* @version 1.0.0 * @version 1.0.0
*/ */
@@ -294,6 +294,7 @@ public class CanalInstanceWithManager extends AbstractCanalInstance {
mysqlEventParser.setFallbackIntervalInSeconds(parameters.getFallbackIntervalInSeconds()); mysqlEventParser.setFallbackIntervalInSeconds(parameters.getFallbackIntervalInSeconds());
mysqlEventParser.setProfilingEnabled(false); mysqlEventParser.setProfilingEnabled(false);
mysqlEventParser.setFilterTableError(parameters.getFilterTableError()); mysqlEventParser.setFilterTableError(parameters.getFilterTableError());
mysqlEventParser.setParallel(parameters.isParallel());
mysqlEventParser.setIsGTIDMode(BooleanUtils.toBoolean(parameters.getGtidEnable())); mysqlEventParser.setIsGTIDMode(BooleanUtils.toBoolean(parameters.getGtidEnable()));
// tsdb // tsdb
if (parameters.getTsdbSnapshotInterval() != null) { if (parameters.getTsdbSnapshotInterval() != null) {
@@ -340,6 +341,7 @@ public class CanalInstanceWithManager extends AbstractCanalInstance {
localBinlogEventParser.setDetectingEnable(parameters.getDetectingEnable()); localBinlogEventParser.setDetectingEnable(parameters.getDetectingEnable());
localBinlogEventParser.setDetectingIntervalInSeconds(parameters.getDetectingIntervalInSeconds()); localBinlogEventParser.setDetectingIntervalInSeconds(parameters.getDetectingIntervalInSeconds());
localBinlogEventParser.setFilterTableError(parameters.getFilterTableError()); localBinlogEventParser.setFilterTableError(parameters.getFilterTableError());
localBinlogEventParser.setParallel(parameters.isParallel());
// 数据库信息，反查表结构时需要 // 数据库信息，反查表结构时需要
if (!CollectionUtils.isEmpty(dbAddresses)) { if (!CollectionUtils.isEmpty(dbAddresses)) {
localBinlogEventParser.setMasterInfo(new AuthenticationInfo(dbAddresses.get(0), localBinlogEventParser.setMasterInfo(new AuthenticationInfo(dbAddresses.get(0),

14
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/model/CanalParameter.java
View File

@@ -12,7 +12,7 @@ import com.alibaba.otter.canal.common.utils.CanalToStringStyle;
/** /**
* canal运行相关参数 * canal运行相关参数
* *
* @author jianghang 2012-7-4 下午02:52:52 * @author jianghang 2012-7-4 下午02:52:52
* @version 1.0.0 * @version 1.0.0
*/ */
@@ -118,6 +118,8 @@ public class CanalParameter implements Serializable {
private String standbyLogfileName = null; // standby起始位置 private String standbyLogfileName = null; // standby起始位置
private Long standbyLogfileOffest = null; private Long standbyLogfileOffest = null;
private Long standbyTimestamp = null; private Long standbyTimestamp = null;
private boolean parallel = true;
public static enum RunMode { public static enum RunMode {
@@ -328,7 +330,7 @@ public class CanalParameter implements Serializable {
/** /**
* 数据来源描述 * 数据来源描述
* *
* @author jianghang 2012-12-26 上午11:05:20 * @author jianghang 2012-12-26 上午11:05:20
* @version 4.1.5 * @version 4.1.5
*/ */
@@ -982,6 +984,14 @@ public class CanalParameter implements Serializable {
this.tsdbSnapshotExpire = tsdbSnapshotExpire; this.tsdbSnapshotExpire = tsdbSnapshotExpire;
} }
public boolean isParallel() {
return parallel;
}
public void setParallel(boolean parallel) {
this.parallel = parallel;
}
public String toString() { public String toString() {
return ToStringBuilder.reflectionToString(this, CanalToStringStyle.DEFAULT_STYLE); return ToStringBuilder.reflectionToString(this, CanalToStringStyle.DEFAULT_STYLE);
} }