alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

Attempted to correct Travis build error

Browse Source
This commit is contained in:
Randall Hauch 2016-01-25 13:50:17 -06:00
parent 5e4c428285
commit 772977f391
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
debezium-core/src/main/java/io/debezium/relational/Tables.java
View File

@ -6,7 +6,6 @@
package io.debezium.relational; package io.debezium.relational;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap; import java.util.HashMap;
import java.util.HashSet; import java.util.HashSet;
import java.util.List; import java.util.List;
@ -86,7 +85,7 @@ public int size() {
public Set<TableId> drainChanges() { public Set<TableId> drainChanges() {
return lock.write(() -> { return lock.write(() -> {
if (changes.isEmpty()) return Collections.<TableId>emptySet(); // if (changes.isEmpty()) return Collections.<TableId>emptySet();
Set<TableId> result = new HashSet<>(changes); Set<TableId> result = new HashSet<>(changes);
changes.clear(); changes.clear();
return result; return result;
@ -306,7 +305,7 @@ public String toString() {
return lock.read(() -> { return lock.read(() -> {
StringBuilder sb = new StringBuilder(); StringBuilder sb = new StringBuilder();
sb.append("Tables {").append(System.lineSeparator()); sb.append("Tables {").append(System.lineSeparator());
tablesByTableId.forEach((tableId,table)->{ tablesByTableId.forEach((tableId, table) -> {
sb.append(" ").append(tableId).append(": {").append(System.lineSeparator()); sb.append(" ").append(tableId).append(": {").append(System.lineSeparator());
table.toString(sb, " "); table.toString(sb, " ");
sb.append(" }").append(System.lineSeparator()); sb.append(" }").append(System.lineSeparator());