HIVE-24082: Expose information whether AcidUtils.ParsedDelta contains statementId (Piotr Findeisen reviewed by Zoltan Haindrich and Peter Vary)
Closes #1438
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java b/ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java
index 991f151..0cb4af9 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java
@@ -1031,8 +1031,12 @@
return path;
}
+ public boolean hasStatementId() {
+ return statementId >= 0;
+ }
+
public int getStatementId() {
- return statementId == -1 ? 0 : statementId;
+ return hasStatementId() ? statementId : 0;
}
public boolean isDeleteDelta() {
