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 <[email protected]> Authored: Thu Oct 26 12:32:20 2017 -0700 Committer: Michael Russo <[email protected]> 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");
