Skip to content

Commit b5c1a82

Browse files
committed
output average time between updates in the update stream
1 parent c9760b0 commit b5c1a82

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/ldbc/socialnet/dbgen/generator/MRGenerateUsers.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,7 @@ public void reduce(LongWritable key, Iterable<Text> valueSet,
125125
protected void cleanup(Context context){
126126
try {
127127
System.out.println("Number of events reduced "+numEvents);
128-
String propertiesStr = new String("gctdeltaduration:"+context.getConfiguration().get("deltaTime")+"\nmin_write_event_start_time:"+min+"\nmax_write_event_start_time:"+max);
128+
String propertiesStr = new String("gctdeltaduration:"+context.getConfiguration().get("deltaTime")+"\nmin_write_event_start_time:"+min+"\nmax_write_event_start_time:"+max+"\nupdate_interleave:"+(max-min)/numEvents);
129129
properties.write(propertiesStr.getBytes("UTF8"));
130130
properties.flush();
131131
properties.close();

0 commit comments

Comments
 (0)