helix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From l...@apache.org
Subject [33/38] helix git commit: Persist the timestamp along with controller leader change history.
Date Wed, 08 Feb 2017 18:00:08 GMT
Persist the timestamp along with controller leader change history.


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

Branch: refs/heads/helix-0.6.x
Commit: ac74e1d3010d91ba99c652d204afc8f7a729c4c1
Parents: fc6009f
Author: Lei Xia <lxia@linkedin.com>
Authored: Tue Aug 30 13:26:52 2016 -0700
Committer: Lei Xia <lxia@linkedin.com>
Committed: Wed Feb 8 09:56:51 2017 -0800

----------------------------------------------------------------------
 .../org/apache/helix/model/LeaderHistory.java   | 36 ++++++++++++++++++++
 1 file changed, 36 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/helix/blob/ac74e1d3/helix-core/src/main/java/org/apache/helix/model/LeaderHistory.java
----------------------------------------------------------------------
diff --git a/helix-core/src/main/java/org/apache/helix/model/LeaderHistory.java b/helix-core/src/main/java/org/apache/helix/model/LeaderHistory.java
index d57fb52..5b3b5d5 100644
--- a/helix-core/src/main/java/org/apache/helix/model/LeaderHistory.java
+++ b/helix-core/src/main/java/org/apache/helix/model/LeaderHistory.java
@@ -19,8 +19,14 @@ package org.apache.helix.model;
  * under the License.
  */
 
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
 import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
+import java.util.TimeZone;
 
 import org.apache.helix.HelixProperty;
 import org.apache.helix.ZNRecord;
@@ -31,6 +37,12 @@ import org.apache.helix.ZNRecord;
 public class LeaderHistory extends HelixProperty {
   private final static int HISTORY_SIZE = 8;
 
+  private enum ConfigProperty {
+    HISTORY,
+    TIME,
+    DATE
+  }
+
   public LeaderHistory(String id) {
     super(id);
   }
@@ -45,6 +57,8 @@ public class LeaderHistory extends HelixProperty {
    * @param instanceName the name of the leader instance
    */
   public void updateHistory(String clusterName, String instanceName) {
+    /* keep this for back-compatible */
+    // TODO: remove this in future when we confirmed no one consumes it
     List<String> list = _record.getListField(clusterName);
     if (list == null) {
       list = new ArrayList<String>();
@@ -55,6 +69,28 @@ public class LeaderHistory extends HelixProperty {
       list.remove(0);
     }
     list.add(instanceName);
+    // TODO: remove above in future when we confirmed no one consumes it */
+
+
+    List<String> historyList = _record.getListField(ConfigProperty.HISTORY.name());
+    if (historyList == null) {
+      historyList = new ArrayList<String>();
+      _record.setListField(ConfigProperty.HISTORY.name(), historyList);
+    }
+
+    if (historyList.size() == HISTORY_SIZE) {
+      historyList.remove(0);
+    }
+
+    Map<String, String> historyEntry = new HashMap<String, String>();
+
+    long currentTime = System.currentTimeMillis();
+    DateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss:SSS");
+    df.setTimeZone(TimeZone.getTimeZone("UTC"));
+    String dateTime = df.format(new Date(currentTime));
+
+    historyEntry.put(ConfigProperty.TIME.name(), String.valueOf(currentTime));
+    historyEntry.put(ConfigProperty.DATE.name(), dateTime);
   }
 
   @Override


Mime
View raw message