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

DBZ-7223 Use Optional attributes

Browse Source
This commit is contained in:
Jiri Pechanec 2024-07-02 11:16:35 +02:00
parent 3799e3d76b
commit 6ba5a1e631
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/sink/converters/SinkDocument.java
View File

@ -10,24 +10,25 @@
import org.bson.BsonDocument;
public final class SinkDocument implements Cloneable {
private final BsonDocument keyDoc;
private final BsonDocument valueDoc;
private final Optional<BsonDocument> keyDoc;
private final Optional<BsonDocument> valueDoc;
public SinkDocument(final BsonDocument keyDoc, final BsonDocument valueDoc) {
this.keyDoc = keyDoc;
this.valueDoc = valueDoc;
this.keyDoc = Optional.ofNullable(keyDoc);
this.valueDoc = Optional.ofNullable(valueDoc);
}
public Optional<BsonDocument> getKeyDoc() {
return Optional.ofNullable(keyDoc);
return keyDoc;
}
public Optional<BsonDocument> getValueDoc() {
return Optional.ofNullable(valueDoc);
return valueDoc;
}
@Override
public SinkDocument clone() {
return new SinkDocument(keyDoc != null ? keyDoc.clone() : null, valueDoc != null ? valueDoc.clone() : null);
return new SinkDocument(keyDoc.isPresent() ? keyDoc.get().clone() : null,
valueDoc.isPresent() ? valueDoc.get().clone() : null);
}
}