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

DBZ-6726 Switch to ArrayList for repeated iteration

Browse Source
This commit is contained in:
Jiri Pechanec 2023-11-09 07:08:37 +01:00
parent 89b07a013e
commit 9d84d01f64
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbStreamingChangeEventSource.java
View File

@ -6,9 +6,8 @@
package io.debezium.connector.mongodb;
import java.time.Duration;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Deque;
import java.util.LinkedList;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.CountDownLatch;
@ -171,7 +170,7 @@ else if (rsOffsetContext.lastTimestamp() != null) {
rsChangeStream.maxAwaitTime(connectorConfig.getCursorMaxAwaitTime(), TimeUnit.MILLISECONDS);
}
var fragmentBuffer = new LinkedList<ChangeStreamDocument<BsonDocument>>();
final List<ChangeStreamDocument<BsonDocument>> fragmentBuffer = new ArrayList<>(16);
try (MongoChangeStreamCursor<ChangeStreamDocument<BsonDocument>> cursor = rsChangeStream.cursor()) {
// In Replicator, this used cursor.hasNext() but this is a blocking call and I observed that this can
@ -275,9 +274,9 @@ protected MongoDbOffsetContext emptyOffsets(MongoDbConnectorConfig connectorConf
}
@SuppressWarnings("DuplicatedCode")
private static ChangeStreamDocument<BsonDocument> mergeEventFragments(Deque<ChangeStreamDocument<BsonDocument>> events) {
private static ChangeStreamDocument<BsonDocument> mergeEventFragments(List<ChangeStreamDocument<BsonDocument>> events) {
var operationTypeString = firstOrNull(events, ChangeStreamDocument::getOperationTypeString);
var resumeToken = events.getLast().getResumeToken();
var resumeToken = events.get(events.size() - 1).getResumeToken();
var namespaceDocument = firstOrNull(events, ChangeStreamDocument::getNamespaceDocument);
var destinationNamespaceDocument = firstOrNull(events, ChangeStreamDocument::getDestinationNamespaceDocument);
var fullDocument = firstOrNull(events, ChangeStreamDocument::getFullDocument);