Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package org.apache.helix.healthcheck;
  
  /*
   * Licensed to the Apache Software Foundation (ASF) under one
   * or more contributor license agreements.  See the NOTICE file
   * distributed with this work for additional information
   * regarding copyright ownership.  The ASF licenses this file
   * to you under the Apache License, Version 2.0 (the
   * "License"); you may not use this file except in compliance
  * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing,
  * software distributed under the License is distributed on an
  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  * KIND, either express or implied.  See the License for the
  * specific language governing permissions and limitations
  * under the License.
  */
 
 import java.util.Map;
 
 
 
   private static final Logger _logger = Logger.getLogger(PerformanceHealthReportProvider.class);
 
   public final static String _testStat = "testStat";
   public final static String _readLatencyStat = "readLatencyStat";
   public final static String _requestCountStat = "requestCountStat";
   public final static String _partitionRequestCountStat = "partitionRequestCountStat";
 
   public static final String _performanceCounters = "performanceCounters";
 
   public int readLatencyCount = 0;
   public double readLatencySum = 0;
 
   public int requestCount = 0;
 
   // private final Map<String, String> _partitionCountsMap = new HashMap<String,
   // String>();
 
   private final Map<StringHashMap<StringString>> _partitionStatMaps =
       new HashMap<StringHashMap<StringString>>();
 
   }
 
   @Override
   public Map<StringStringgetRecentHealthReport() {
     long testStat = 10;
 
     Map<StringStringresult = new TreeMap<StringString>();
 
     result.put("" + testStat);
     result.put("" +  / );
     result.put("" + );
 
     return result;
   }
 
   @Override
     Map<StringMap<StringString>> result = new TreeMap<StringMap<StringString>>();
     for (String statName : .keySet()) {
       result.put(statName.get(statName));
     }
     return result;
   }
 
   HashMap<StringStringgetStatMap(String statNameboolean createIfMissing) {
     // check if map for this stat exists. if not, create it
     HashMap<StringStringstatMap;
     if (!.containsKey(statName)) {
       if (!createIfMissing) {
         return null;
       }
       statMap = new HashMap<StringString>();
       .put(statNamestatMap);
     } else {
       statMap = .get(statName);
     }
     return statMap;
   }
 
   // TODO:
   // Currently participant is source of truth and updates ZK. We want ZK to be
   // source of truth.
   // Revise this approach the participant sends deltas of stats to controller
   // (ZK?) and have controller do aggregation
   // and update ZK. Make sure to wipe the participant between uploads.
   String getPartitionStat(HashMap<StringStringpartitionMapString partitionName) {
     return partitionMap.get(partitionName);
   }
 
  void setPartitionStat(HashMap<StringStringpartitionMapString partitionNameString value) {
    partitionMap.put(partitionNamevalue);
  }
  public void incrementPartitionStat(String statNameString partitionName) {
    HashMap<StringStringstatMap = getStatMap(statNametrue);
    String currValStr = getPartitionStat(statMappartitionName);
    double currVal;
    if (currValStr == null) {
      currVal = 1.0;
    } else {
      currVal = Double.parseDouble(getPartitionStat(statMappartitionName));
      currVal++;
    }
    setPartitionStat(statMappartitionName, String.valueOf(currVal));
  }
  public void submitPartitionStat(String statNameString partitionNameString value) {
    HashMap<StringStringstatMap = getStatMap(statNametrue);
    setPartitionStat(statMappartitionNamevalue);
  }
  public String getPartitionStat(String statNameString partitionName) {
    HashMap<StringStringstatMap = getStatMap(statNamefalse);
    if (statMap == null) {
      return null;
    } else {
      return statMap.get(partitionName);
    }
  }
  public void resetStats() {
  }
  public String getReportName() {
    return ;
  }
New to GrepCode? Check out our FAQ X