From 04d6cc483b8556e16fe8c7004a35b366edb3d44b Mon Sep 17 00:00:00 2001 From: Allison Portis Date: Wed, 26 Feb 2025 20:19:44 -0800 Subject: [PATCH] require non null checks) --- .../kernel/internal/actions/CommitInfo.java | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/kernel/kernel-api/src/main/java/io/delta/kernel/internal/actions/CommitInfo.java b/kernel/kernel-api/src/main/java/io/delta/kernel/internal/actions/CommitInfo.java index fedfa8088a1..878c733f068 100644 --- a/kernel/kernel-api/src/main/java/io/delta/kernel/internal/actions/CommitInfo.java +++ b/kernel/kernel-api/src/main/java/io/delta/kernel/internal/actions/CommitInfo.java @@ -18,6 +18,7 @@ import static io.delta.kernel.internal.DeltaErrors.wrapEngineExceptionThrowsIO; import static io.delta.kernel.internal.util.Utils.singletonCloseableIterator; import static io.delta.kernel.internal.util.VectorUtils.stringStringMapValue; +import static java.util.Objects.requireNonNull; import static java.util.stream.Collectors.toMap; import io.delta.kernel.data.ColumnVector; @@ -125,14 +126,14 @@ public CommitInfo( boolean isBlindAppend, String txnId, Map operationMetrics) { - this.inCommitTimestamp = inCommitTimestamp; + this.inCommitTimestamp = requireNonNull(inCommitTimestamp); this.timestamp = timestamp; - this.engineInfo = engineInfo; - this.operation = operation; - this.operationParameters = Collections.unmodifiableMap(operationParameters); + this.engineInfo = requireNonNull(engineInfo); + this.operation = requireNonNull(operation); + this.operationParameters = Collections.unmodifiableMap(requireNonNull(operationParagmeters)); this.isBlindAppend = isBlindAppend; - this.txnId = txnId; - this.operationMetrics = Collections.unmodifiableMap(operationMetrics); + this.txnId = requireNonNull(txnId); + this.operationMetrics = Collections.unmodifiableMap(requireNonNull(operationMetrics)); } public long getTimestamp() { @@ -162,7 +163,7 @@ public String getTxnId() { public Optional getInCommitTimestamp() { return inCommitTimestamp; } - +gi public Map getOperationMetrics() { return operationMetrics; } @@ -170,7 +171,7 @@ public Map getOperationMetrics() { public void setInCommitTimestamp(Optional inCommitTimestamp) { this.inCommitTimestamp = inCommitTimestamp; } - + /** * Encode as a {@link Row} object with the schema {@link CommitInfo#FULL_SCHEMA}. *