Add filter.matches to tableMapCache

seanlook · Dec 25, 2017 · 2618b70303078bf910a1981b69943cca75ee04fb · 2618b70
1 parent 4acddf4
commit 2618b70303078bf910a1981b69943cca75ee04fb
Unified Split

Showing with 7 additions and 3 deletions.

+7 −3 src/main/java/com/zendesk/maxwell/replication/TableCache.java
diff --git a/src/main/java/com/zendesk/maxwell/replication/TableCache.java b/src/main/java/com/zendesk/maxwell/replication/TableCache.java
@@ -14,9 +14,13 @@

 	public void processEvent(Schema schema, MaxwellFilter filter, Long tableId, String dbName, String tblName) {
 		if ( !tableMapCache.containsKey(tableId) ) {
-			if ( filter != null && filter.isTableBlacklisted(dbName, tblName) ) {
-				blacklistedTableCache.put(tableId, tblName);
-				return;
+			if ( filter != null ) {
+				if ( filter.isTableBlacklisted(dbName, tblName) ) {
+					blacklistedTableCache.put(tableId, tblName);
+					return;
+				}
+				else if ( !filter.matches(dbName, tblName) ) 
+					return;
 			}

 			Database db = schema.findDatabase(dbName);