Skip to content

Commit f90fed4

Browse files
committed
Added person activity generation throughput reporting
1 parent a70ea96 commit f90fed4

File tree

1 file changed

+3
-11
lines changed

1 file changed

+3
-11
lines changed

src/main/java/ldbc/snb/datagen/generator/PersonActivityGenerator.java

Lines changed: 3 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -221,25 +221,17 @@ public void generateActivityForBlock( int seed, ArrayList<Person> block, Context
221221
System.out.println("Generating activity for peron"+counter);
222222
long start = System.currentTimeMillis();
223223
generateActivity(p, block);
224-
float time = (System.currentTimeMillis() - start)/1000.0f;
225-
personGenerationTime+=time;
226-
accumTime += time;
227-
System.out.println("Time to generate activity for person "+counter+": "+time+". Time so far "+accumTime);
228-
start = System.currentTimeMillis();
229224
if( DatagenParams.updateStreams ) {
230225
updateSerializer_.changePartition();
231226
}
232-
time = (System.currentTimeMillis() - start)/1000.0f;
233-
accumTime += time;
234-
System.out.println("Time to change partition "+time+". Time so far "+accumTime);
235-
start = System.currentTimeMillis();
236227
if( counter % 100 == 0 ) {
237228
context.setStatus("Generating activity of person "+counter+" of block"+seed);
238229
context.progress();
239230
}
240-
time = (System.currentTimeMillis() - start)/1000.0f;
231+
float time = (System.currentTimeMillis() - start)/1000.0f;
232+
personGenerationTime+=time;
241233
accumTime += time;
242-
System.out.println("Time to report "+time+". Time so far "+accumTime);
234+
System.out.println("Time to generate activity for person "+counter+": "+time+". Throughput "+counter/accumTime);
243235
counter++;
244236
}
245237
System.out.println("Average person activity generation time "+personGenerationTime / (float)block.size());

0 commit comments

Comments
 (0)