[kudu] branch master updated: [java] KUDU-3035: Pass last propagated timestamp in Batch

[ad...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

adar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kudu.git


The following commit(s) were added to refs/heads/master by this push:
     new 90c12dc  [java] KUDU-3035: Pass last propagated timestamp in Batch
90c12dc is described below

commit 90c12dc27ef716e7ba8397e74251b69ef38f1984
Author: Andy Singer <an...@gmail.com>
AuthorDate: Sun Jan 12 10:54:55 2020 -0500

    [java] KUDU-3035: Pass last propagated timestamp in Batch
    
    Change-Id: I056d19130bf8cb6a2dbc72a02af4c4ae8d7181e9
    Reviewed-on: http://gerrit.cloudera.org:8080/15017
    Tested-by: Kudu Jenkins
    Reviewed-by: Adar Dembo <ad...@cloudera.com>
---
 java/kudu-client/src/main/java/org/apache/kudu/client/Batch.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/java/kudu-client/src/main/java/org/apache/kudu/client/Batch.java b/java/kudu-client/src/main/java/org/apache/kudu/client/Batch.java
index 4d715af..9e2c086 100644
--- a/java/kudu-client/src/main/java/org/apache/kudu/client/Batch.java
+++ b/java/kudu-client/src/main/java/org/apache/kudu/client/Batch.java
@@ -142,6 +142,9 @@ class Batch extends KuduRpc<BatchResponse> {
                              (long)builder.getRowOperations().getIndirectData().size();
     builder.setTabletId(UnsafeByteOperations.unsafeWrap(getTablet().getTabletIdAsBytes()));
     builder.setExternalConsistencyMode(externalConsistencyMode.pbVersion());
+    if (this.propagatedTimestamp != AsyncKuduClient.NO_TIMESTAMP) {
+      builder.setPropagatedTimestamp(this.propagatedTimestamp);
+    }
     if (authzToken != null) {
       builder.setAuthzToken(authzToken);
     }