Skip to content

Commit c9efb1d

Browse files
author
Hadoop user
committed
2 parents 36e7964 + cc2372c commit c9efb1d

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -322,6 +322,7 @@ public int runGenerateJob(Configuration conf) throws Exception {
322322

323323
if(conf.getBoolean("ldbc.snb.datagen.parametergenerator.parameters",false) && conf.getBoolean("ldbc.snb.datagen.generator.activity",false)) {
324324
System.out.println("Running Parameter Generation");
325+
System.out.println("Generating Interactive Parameters");
325326
ProcessBuilder pb = new ProcessBuilder("mkdir", "-p",conf.get("ldbc.snb.datagen.serializer.outputDir")+"/substitution_parameters");
326327
pb.directory(new File("./"));
327328
Process p = pb.start();
@@ -335,13 +336,15 @@ public int runGenerateJob(Configuration conf) throws Exception {
335336
p = pb.start();
336337
p.waitFor();
337338

339+
System.out.println("Generating BI Parameters");
338340
pb = new ProcessBuilder(conf.get("ldbc.snb.datagen.parametergenerator.python"), "paramgenerator/generateparamsbi.py", "./",conf.get("ldbc.snb.datagen.serializer.outputDir")+"/substitution_parameters");
339341
pb.directory(new File("./"));
340342
File logBi = new File("parameters_bi.log");
341343
pb.redirectErrorStream(true);
342344
pb.redirectOutput(ProcessBuilder.Redirect.appendTo(logBi));
343345
p = pb.start();
344346
p.waitFor();
347+
System.out.println("Finished Parameter Generation");
345348
}
346349
return 0;
347350
}

0 commit comments

Comments
 (0)