Skip to content

Commit 6f5e0b0

Browse files
committed
Added prefix to update stream properties variable files
1 parent 5d30e9b commit 6f5e0b0

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -620,11 +620,11 @@ public int runGenerateJob(Configuration conf) throws Exception {
620620

621621
if(conf.getBoolean("updateStreams",false)) {
622622
OutputStream output = fs.create(new Path(conf.get("outputDir") + "/social_network/updateStream.properties"));
623-
output.write(new String("gctdeltaduration:"+conf.get("deltaTime")+"\n").getBytes());
624-
output.write(new String("min_write_event_start_time:"+min+"\n").getBytes());
625-
output.write(new String("max_write_event_start_time:"+max+"\n").getBytes());
626-
output.write(new String("update_interleave:"+(max-min)/numEvents+"\n").getBytes());
627-
output.write(new String("num_events:"+numEvents).getBytes());
623+
output.write(new String("ldbc.snb.interactive.gctdeltaduration:"+conf.get("deltaTime")+"\n").getBytes());
624+
output.write(new String("ldbc.snb.interactive.min_write_event_start_time:"+min+"\n").getBytes());
625+
output.write(new String("ldbc.snb.interactive.max_write_event_start_time:"+max+"\n").getBytes());
626+
output.write(new String("ldbc.snb.interactive.update_interleave:"+(max-min)/numEvents+"\n").getBytes());
627+
output.write(new String("ldbc.snb.interactive.num_events:"+numEvents).getBytes());
628628
output.close();
629629
}
630630

0 commit comments

Comments
 (0)