usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mru...@apache.org
Subject usergrid git commit: Add entity version to EntityVersionAudit csv file.
Date Thu, 26 Oct 2017 19:32:36 GMT
Repository: usergrid
Updated Branches:
  refs/heads/master c8282f04b -> 598ed29a1


Add entity version to EntityVersionAudit csv file.


Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/598ed29a
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/598ed29a
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/598ed29a

Branch: refs/heads/master
Commit: 598ed29a107e6af2905e708d5b9f1df27bb10679
Parents: c8282f0
Author: Michael Russo <russomichael@google.com>
Authored: Thu Oct 26 12:32:20 2017 -0700
Committer: Michael Russo <russomichael@google.com>
Committed: Thu Oct 26 12:32:20 2017 -0700

----------------------------------------------------------------------
 .../java/org/apache/usergrid/tools/EntityVersionAudit.java  | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/usergrid/blob/598ed29a/stack/tools/src/main/java/org/apache/usergrid/tools/EntityVersionAudit.java
----------------------------------------------------------------------
diff --git a/stack/tools/src/main/java/org/apache/usergrid/tools/EntityVersionAudit.java b/stack/tools/src/main/java/org/apache/usergrid/tools/EntityVersionAudit.java
index c9f4860..ee064bc 100644
--- a/stack/tools/src/main/java/org/apache/usergrid/tools/EntityVersionAudit.java
+++ b/stack/tools/src/main/java/org/apache/usergrid/tools/EntityVersionAudit.java
@@ -189,7 +189,7 @@ public class EntityVersionAudit extends ToolBase {
         final Writer versionAuditWriter = new BufferedWriter(new OutputStreamWriter(new FileOutputStream("entity_version_audit.txt"),
"utf-8"));
         final Writer versionAggWriter = new BufferedWriter(new OutputStreamWriter(new FileOutputStream("entity_version_agg.txt"),
"utf-8"));
 
-        versionAuditWriter.write("collection,entityUUID,cassandraTimestamp,elasticsearchTimestamp,indexDelayMillis,existsInElasticsearch\n");
+        versionAuditWriter.write("collection,entityUUID,entityVersion,cassandraTimestamp,elasticsearchTimestamp,indexDelayMillis,existsInElasticsearch\n");
         versionAuditWriter.flush();
 
         final EsProvider esProvider = injector.getInstance(EsProvider.class);
@@ -239,9 +239,10 @@ public class EntityVersionAudit extends ToolBase {
                                 String csvLine =
                                     collectionName + "," +
                                     uuid + "," +
-                                        uuidTimestamp + "," +
-                                        indexTimestamp + "," +
-                                        diff + "," +
+                                    mvccLogEntry.getVersion() + "," +
+                                    uuidTimestamp + "," +
+                                    indexTimestamp + "," +
+                                    diff + "," +
                                     exists;
 
                                 //final String url = "/"+readAlias+"/entity/"+URLEncoder.encode(esDocId,
"UTF-8");


Mime
View raw message