Skip to content

Commit

Permalink
require non null checks)
Browse files Browse the repository at this point in the history
  • Loading branch information
allisonport-db committed Feb 27, 2025
1 parent 6294818 commit 04d6cc4
Showing 1 changed file with 9 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -125,14 +126,14 @@ public CommitInfo(
boolean isBlindAppend,
String txnId,
Map<String, String> 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() {
Expand Down Expand Up @@ -162,15 +163,15 @@ public String getTxnId() {
public Optional<Long> getInCommitTimestamp() {
return inCommitTimestamp;
}

gi
public Map<String, String> getOperationMetrics() {
return operationMetrics;
}

public void setInCommitTimestamp(Optional<Long> inCommitTimestamp) {
this.inCommitTimestamp = inCommitTimestamp;
}

/**
* Encode as a {@link Row} object with the schema {@link CommitInfo#FULL_SCHEMA}.
*
Expand Down

0 comments on commit 04d6cc4

Please sign in to comment.