Page MenuHomec4science
Files F90835178

Measurements.java
No OneTemporary
Actions

File Metadata

Created
Tue, Nov 5, 05:06

Measurements.java
View Options

/**
* Copyright (c) 2010 Yahoo! Inc. All rights reserved.
*
* Licensed 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. See accompanying
* LICENSE file.
*/
package com.yahoo.ycsb.measurements;
import java.io.PrintStream;
import java.util.HashMap;
import java.util.Properties;
/**
* Collects latency measurements, and reports them when requested.
*
* @author cooperb
*
*/
public class Measurements
{
private static final String MEASUREMENT_TYPE = "measurementtype";
private static final String MEASUREMENT_TYPE_DEFAULT = "histogram";
static Measurements singleton=null;
static Properties measurementproperties=null;
public static void setProperties(Properties props)
{
measurementproperties=props;
}
/**
* Return the singleton Measurements object.
*/
public synchronized static Measurements getMeasurements()
{
if (singleton==null)
{
singleton=new Measurements(measurementproperties);
}
return singleton;
}
HashMap<String,OneMeasurement> data;
boolean histogram=true;
private Properties _props;
/**
* Create a new object with the specified properties.
*/
public Measurements(Properties props)
{
data=new HashMap<String,OneMeasurement>();
_props=props;
if (_props.getProperty(MEASUREMENT_TYPE, MEASUREMENT_TYPE_DEFAULT).compareTo("histogram")==0)
{
histogram=true;
}
else
{
histogram=false;
}
}
OneMeasurement constructOneMeasurement(String name)
{
if (histogram)
{
return new OneMeasurementHistogram(name,_props);
}
else
{
return new OneMeasurementTimeSeries(name,_props);
}
}
/**
* Report a single value of a single metric. E.g. for read latency, operation="READ" and latency is the measured value.
*/
public synchronized void measure(String operation, int latency)
{
if (!data.containsKey(operation))
{
synchronized(this)
{
if (!data.containsKey(operation))
{
data.put(operation,constructOneMeasurement(operation));
}
}
}
try
{
data.get(operation).measure(latency);
}
catch (java.lang.ArrayIndexOutOfBoundsException e)
{
System.out.println("ERROR: java.lang.ArrayIndexOutOfBoundsException - ignoring and continuing");
e.printStackTrace();
e.printStackTrace(System.out);
}
}
/**
* Report a return code for a single DB operaiton.
*/
public void reportReturnCode(String operation, int code)
{
if (!data.containsKey(operation))
{
synchronized(this)
{
if (!data.containsKey(operation))
{
data.put(operation,constructOneMeasurement(operation));
}
}
}
data.get(operation).reportReturnCode(code);
}
/**
* Print the full report to the listed PrintStream.
*/
public void printReport(PrintStream out)
{
for (OneMeasurement m : data.values())
{
m.printReport(out);
}
}
/**
* Return a one line summary of the measurements.
*/
public String getSummary()
{
String ret="";
for (OneMeasurement m : data.values())
{
ret+=m.getSummary()+" ";
}
return ret;
}
}

Event Timeline

c4science · Help