You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pv...@apache.org on 2020/09/25 11:22:58 UTC
[hive] branch master updated: HIVE-24082: Expose information
whether AcidUtils.ParsedDelta contains statementId (Piotr Findeisen
reviewed by Zoltan Haindrich and Peter Vary)
This is an automated email from the ASF dual-hosted git repository.
pvary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/master by this push:
new 140c445 HIVE-24082: Expose information whether AcidUtils.ParsedDelta contains statementId (Piotr Findeisen reviewed by Zoltan Haindrich and Peter Vary)
140c445 is described below
commit 140c445b23a07de47a8a62c35cd8e223cc137024
Author: Piotr Findeisen <pi...@gmail.com>
AuthorDate: Fri Sep 25 13:22:36 2020 +0200
HIVE-24082: Expose information whether AcidUtils.ParsedDelta contains statementId (Piotr Findeisen reviewed by Zoltan Haindrich and Peter Vary)
Closes #1438
---
ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
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 @@ public class AcidUtils {
return path;
}
+ public boolean hasStatementId() {
+ return statementId >= 0;
+ }
+
public int getStatementId() {
- return statementId == -1 ? 0 : statementId;
+ return hasStatementId() ? statementId : 0;
}
public boolean isDeleteDelta() {