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

= performance improve

Browse Source 
- using bulk operation instead of iteration if possible
  - terminate loop after condition is met
This commit is contained in:
zavakid
2020-09-18 00:51:10 +08:00
parent e7de8289cd
commit 435db30b7b
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/DatabaseTableMeta.java
View File

@@ -191,9 +191,7 @@ public class DatabaseTableMeta implements TableMetaTSDB {
try { try {
ResultSetPacket packet = connection.query("show databases"); ResultSetPacket packet = connection.query("show databases");
List<String> schemas = new ArrayList<>(); List<String> schemas = new ArrayList<>();
for (String schema : packet.getFieldValues()) { schemas.addAll(packet.getFieldValues());
schemas.add(schema);
}
for (String schema : schemas) { for (String schema : schemas) {
// filter views // filter views

1
sink/src/main/java/com/alibaba/otter/canal/sink/entry/HeartBeatEntryEventHandler.java
View File

@@ -20,6 +20,7 @@ public class HeartBeatEntryEventHandler extends AbstractCanalEventDownStreamHand
for (Event event : events) { for (Event event : events) {
if (event.getEntryType() == EntryType.HEARTBEAT) { if (event.getEntryType() == EntryType.HEARTBEAT) {
existHeartBeat = true; existHeartBeat = true;
break;
} }
} }