Skip to content

Commit

Permalink
update comments
Browse files Browse the repository at this point in the history
  • Loading branch information
huan233usc committed Jan 22, 2025
1 parent 6eff126 commit 69c29df
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -31,9 +31,9 @@ public class CRCInfo {

public static Optional<CRCInfo> fromColumnarBatch(
Engine engine, long version, ColumnarBatch batch, int rowId, String crcFilePath) {
// fromColumnVector already takes care of nulls
Protocol protocol = Protocol.fromColumnVector(batch.getColumnVector(PROTOCOL_ORDINAL), rowId);
Metadata metadata = Metadata.fromColumnVector(batch.getColumnVector(METADATA_ORDINAL), rowId);
// protocol and metadata are nullable per fromColumnVector's implementation.
if (protocol == null || metadata == null) {
logger.warn("Invalid checksum file missing protocol and/or metadata: {}", crcFilePath);
return Optional.empty();
Expand Down

0 comments on commit 69c29df

Please sign in to comment.