Skip to content

Commit adc7cb3

Browse files
author
Tobias Hafner
committed
Fix analysis report
1 parent 0b979ca commit adc7cb3

3 files changed

Lines changed: 14 additions & 9 deletions

File tree

src/main/java/org/polypheny/simpleclient/scenario/scalingBench/ErrorHandlingEvaluationThread.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@ protected void executeAndMeasure( QueryListEntry queryListEntry ) {
6565
executor.executeQuery( queryListEntry.query );
6666

6767
long measuredTime = System.nanoTime() - startTime;
68+
6869
measuredTimes.add( measuredTime );
6970
measuredTimePerQueryType.get( queryListEntry.templateId ).add( measuredTime );
7071
for ( Integer id : queryListEntry.templateIds ) {

src/main/java/org/polypheny/simpleclient/scenario/scalingBench/ErrorHandlingPolyphenyScenario.java

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -114,18 +114,23 @@ protected long commonExecuteWithExpectedErrors( List<QueryListEntry> queries, Pr
114114
@Override
115115
public void analyze( Properties properties, File outputDirectory ) {
116116
properties.put( "executeRuntime [s]", executeRuntime / 1000000000.0 );
117-
properties.put( "measuredTime [ns]", calculateMean( measuredTimes ) );
117+
properties.put( "measuredTime [ms]", calculateMean( measuredTimes ) );
118118

119-
properties.put( "numberOfQueries", measuredTimes.size() + failedQueries );
120-
properties.put( "numberOfSuccessfulQueries", measuredTimes.size() );
119+
properties.put( "numberOfQueries", measuredTimes.size());
120+
properties.put( "numberOfSuccessfulQueries", measuredTimes.size() - failedQueries);
121121
properties.put( "numberOfFailedQueries", failedQueries );
122+
properties.put("successRatio", calculateSuccessRatio() );
122123

123124
properties.put( "throughput [succ.q/s]", measuredTimes.size() / (executeRuntime / 1000000000.0) );
124-
properties.put( "querySuccessRatio", measuredTimes.size() / (measuredTimes.size() + failedQueries));
125125

126126
measuredTimePerQueryType.forEach( ( templateId, time ) -> calculateResults( queryTypes, properties, templateId, time ) );
127127
properties.put( "queryTypes_maxId", queryTypes.size() );
128128
}
129129

130+
private double calculateSuccessRatio() {
131+
double unroundedRatio = (1.0 * measuredTimes.size() - failedQueries) / measuredTimes.size();
132+
return Math.round( unroundedRatio * 100.0 ) / 100.0;
133+
}
134+
130135

131136
}

src/main/java/org/polypheny/simpleclient/scenario/scalingBench/LockingBench.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -183,11 +183,10 @@ public synchronized void store( OutputStream out, String comments) throws IOExce
183183
File analysisFile = new File(outputDirectory, fileName);
184184
analyze(analysis, analysisFile);
185185

186-
analysis.put( "number_of_sessions", config.sessionCount );
187-
analysis.put( "number_of_namespaces", config.namespaceCount );
188-
analysis.put("number_of_entities_per_namespace", config.entityCount );
189-
analysis.put( "number_of_queries", config.numberOfQueries );
190-
analysis.put( "read_write_ratio", config.readWriteRatio );
186+
analysis.put( "numberOfSessions", config.sessionCount );
187+
analysis.put( "numberOfNamespaces", config.namespaceCount );
188+
analysis.put("numberOfEntitiesPerNamespace", config.entityCount );
189+
analysis.put( "readWriteRatio", config.readWriteRatio );
191190

192191
try (FileOutputStream out = new FileOutputStream(analysisFile)) {
193192
analysis.store(out, "Analysis results");

0 commit comments

Comments
 (0)