Differential D1846 Diff 6214 java/server/src/main/java/org/softwareheritage/graph/benchmark/Common.java

Changeset View

Standalone View

java/server/src/main/java/org/softwareheritage/graph/benchmark/Common.java

This file was added.

				package org.softwareheritage.graph.benchmark;

				import java.util.ArrayList;
				import java.util.function.Function;

				import org.softwareheritage.graph.Endpoint;
				import org.softwareheritage.graph.Graph;
				import org.softwareheritage.graph.SwhPID;
				import org.softwareheritage.graph.utils.Statistics;

				/**
				* Benchmark common utility functions.
				*
				* @author Thibault Allançon
				* @version 0.0.1
				* @since 0.0.1
				*/

				public class Common {
				/**
				* Times a specific endpoint and prints aggregated statistics.
				*
				* @param graph compressed graph used in the benchmark
				* @param nodeIds node ids to use as starting point for the endpoint traversal
				* @param operation endpoint function to benchmark
				*/
				public static void timeEndpoint(
				Graph graph, long[] nodeIds, Function<SwhPID, Endpoint.Output> operation) {
				ArrayList<Double> timings = new ArrayList<>();
				ArrayList<Double> timingsNormalized = new ArrayList<>();

				for (long nodeId : nodeIds) {
				SwhPID swhPID = graph.getSwhPID(nodeId);

				Endpoint.Output output = operation.apply(swhPID);

				timings.add(output.meta.timings.traversal);
				if (output.meta.nbEdgesAccessed != 0) {
				timingsNormalized.add(output.meta.timings.traversal / output.meta.nbEdgesAccessed);
				}
				}

				zackUnsubmitted Not Done Inline Actions I haven't checked the code as I'm on my phone, but Statistics sounds like the right place where you want to compute the avg. You should just make sure the raw data needed to do so reach it. zack: I haven't checked the code as I'm on my phone, but Statistics sounds like the right place where…
				haltodeAuthorUnsubmitted Done Inline Actions Right now the Statistics class is a general class to compute stats on double values because AccessEdge does not handle `Endpoint.Output` but raw timings. I'll try to think about a way to have a more specific endpoint related statistics class/methods. haltode: Right now the Statistics class is a general class to compute stats on double values because…
				System.out.println("timings:");
				Statistics stats = new Statistics(timings);
				stats.printAll();

				System.out.println("timings normalized:");
				Statistics statsNormalized = new Statistics(timingsNormalized);
				statsNormalized.printAll();
				}
				}