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

[optimization] Prevent unnecessary list creation

Browse Source 
Prevent unnecessary list creation
This commit is contained in:
Erdinç Taşkın 2022-11-25 21:44:59 +03:00 committed by Jiri Pechanec
parent 68412ce15f
commit 97548591d6
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbConnectorTask.java
View File

@ -163,7 +163,7 @@ private MongoDbOffsetContext getPreviousOffset(MongoDbConnectorConfig connectorC
Collection<Map<String, String>> partitions = loader.getPartitions();
Map<Map<String, String>, Map<String, Object>> offsets = context.offsetStorageReader().offsets(partitions);
if (offsets != null && !offsets.values().stream().filter(Objects::nonNull).collect(Collectors.toList()).isEmpty()) {
if (offsets != null && offsets.values().stream().anyMatch(Objects::nonNull)) {
MongoDbOffsetContext offsetContext = loader.loadOffsets(offsets);
logger.info("Found previous offsets {}", offsetContext);
return offsetContext;