Now the endline separator can be configured by means of the ldbc.snb.datagen.serialized.endlineSeparator option

ArnauPrat · ArnauPrat · commit d67cf5fe4d0c · 2016-01-08T11:59:47.000+01:00
Updated all the serializers to accept the option
diff --git a/src/main/java/ldbc/snb/datagen/serializer/graphalytics/CSVPersonSerializer.java b/src/main/java/ldbc/snb/datagen/serializer/graphalytics/CSVPersonSerializer.java
@@ -72,7 +72,7 @@ public void initialize(Configuration conf, int reducerId) {
         int numFiles = FileNames.values().length;
         writers = new HDFSCSVWriter[numFiles];
         for( int i = 0; i < numFiles; ++i) {
-            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"), FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|", false);
+            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"), FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|", conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));
         }
 
         ArrayList<String> arguments = new ArrayList<String>();
diff --git a/src/main/java/ldbc/snb/datagen/serializer/graphalytics/CSVPersonSerializerWithWeights.java b/src/main/java/ldbc/snb/datagen/serializer/graphalytics/CSVPersonSerializerWithWeights.java
@@ -74,7 +74,7 @@ public void initialize(Configuration conf, int reducerId) {
         int numFiles = FileNames.values().length;
         writers = new HDFSCSVWriter[numFiles];
         for( int i = 0; i < numFiles; ++i) {
-            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"), FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|", false);
+            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"), FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|", conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));
         }
 
         ArrayList<String> arguments = new ArrayList<String>();
diff --git a/src/main/java/ldbc/snb/datagen/serializer/small/CSVInvariantSerializer.java b/src/main/java/ldbc/snb/datagen/serializer/small/CSVInvariantSerializer.java
@@ -37,7 +37,7 @@ public void initialize(Configuration conf, int reducerId) {
         int numFiles = FileNames.values().length;
         writers = new HDFSCSVWriter[numFiles];
         for( int i = 0; i < numFiles; ++i) {
-            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|", false);
+            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|", conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));
         }
 
         ArrayList<String> arguments = new ArrayList<String>();
diff --git a/src/main/java/ldbc/snb/datagen/serializer/small/CSVPersonActivitySerializer.java b/src/main/java/ldbc/snb/datagen/serializer/small/CSVPersonActivitySerializer.java
@@ -42,7 +42,7 @@ public void initialize(Configuration conf, int reducerId) {
         int numFiles = FileNames.values().length;
         writers = new HDFSCSVWriter[numFiles];
         for( int i = 0; i < numFiles; ++i) {
-            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|", false);
+            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|", conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));
         }
         arguments = new ArrayList<String>();
 
diff --git a/src/main/java/ldbc/snb/datagen/serializer/small/CSVPersonSerializer.java b/src/main/java/ldbc/snb/datagen/serializer/small/CSVPersonSerializer.java
@@ -75,7 +75,7 @@ public void initialize(Configuration conf, int reducerId) {
         int numFiles = FileNames.values().length;
         writers = new HDFSCSVWriter[numFiles];
         for( int i = 0; i < numFiles; ++i) {
-            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|", false);
+            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|", conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));
         }
 
         ArrayList<String> arguments = new ArrayList<String>();
diff --git a/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVInvariantSerializer.java b/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVInvariantSerializer.java
@@ -48,7 +48,7 @@ public void initialize(Configuration conf, int reducerId) {
         int numFiles = FileNames.values().length;
         writers = new HDFSCSVWriter[numFiles];
         for( int i = 0; i < numFiles; ++i) {
-            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|",false);
+            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|",conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));
         }
 
         ArrayList<String> arguments = new ArrayList<String>();
diff --git a/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVMergeForeignInvariantSerializer.java b/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVMergeForeignInvariantSerializer.java
@@ -42,7 +42,7 @@ public void initialize(Configuration conf, int reducerId) {
         int numFiles = FileNames.values().length;
         writers = new HDFSCSVWriter[numFiles];
         for( int i = 0; i < numFiles; ++i) {
-            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|",false);
+            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|",conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));
         }
 
         ArrayList<String> arguments = new ArrayList<String>();
diff --git a/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVMergeForeignPersonActivitySerializer.java b/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVMergeForeignPersonActivitySerializer.java
@@ -45,7 +45,7 @@ public void initialize(Configuration conf, int reducerId) {
         int numFiles = FileNames.values().length;
         writers = new HDFSCSVWriter[numFiles];
         for( int i = 0; i < numFiles; ++i) {
-            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|",false);
+            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|",conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));
         }
         arguments = new ArrayList<String>();
 
diff --git a/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVMergeForeignPersonSerializer.java b/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVMergeForeignPersonSerializer.java
@@ -45,7 +45,7 @@ public void initialize(Configuration conf, int reducerId) {
         int numFiles = FileNames.values().length;
         writers = new HDFSCSVWriter[numFiles];
         for( int i = 0; i < numFiles; ++i) {
-            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|",false);
+            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|", conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));
         }
 
         ArrayList<String> arguments = new ArrayList<String>();
diff --git a/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVPersonActivitySerializer.java b/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVPersonActivitySerializer.java
@@ -59,7 +59,7 @@ public void initialize(Configuration conf, int reducerId) {
 		int numFiles = FileNames.values().length;
 		writers = new HDFSCSVWriter[numFiles];
 		for( int i = 0; i < numFiles; ++i) {
-			writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|",false);
+			writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|",conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false) );
 		}
 		arguments = new ArrayList<String>();
 
diff --git a/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVPersonSerializer.java b/src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVPersonSerializer.java
@@ -81,7 +81,7 @@ public void initialize(Configuration conf, int reducerId) {
         int numFiles = FileNames.values().length;
         writers = new HDFSCSVWriter[numFiles];
         for( int i = 0; i < numFiles; ++i) {
-            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|",false);
+            writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"|",conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));
         }
 
         ArrayList<String> arguments = new ArrayList<String>();
diff --git a/src/main/java/ldbc/snb/datagen/util/ConfigParser.java b/src/main/java/ldbc/snb/datagen/util/ConfigParser.java
@@ -44,6 +44,7 @@ public static Configuration initialize() {
         conf.set("ldbc.snb.datagen.serializer.outputDir", "./");
         conf.set("ldbc.snb.datagen.serializer.socialNetworkDir", "./social_network");
         conf.set("ldbc.snb.datagen.serializer.hadoopDir", "./hadoop");
+        conf.set("ldbc.snb.datagen.serializer.endlineSeparator", Boolean.toString(false));
         conf.set("ldbc.snb.datagen.generator.deltaTime", "10000");
         conf.set("ldbc.snb.datagen.generator.activity", "true");
 

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ public void initialize(Configuration conf, int reducerId) {`
`72`	`72`	`int numFiles = FileNames.values().length;`
`73`	`73`	`writers = new HDFSCSVWriter[numFiles];`
`74`	`74`	`for( int i = 0; i < numFiles; ++i) {`
`75`		`- writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"), FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|", false);`
	`75`	`+ writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"), FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|", conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));`
`76`	`76`	`}`
`77`	`77`
`78`	`78`	`ArrayList<String> arguments = new ArrayList<String>();`
Original file line number	Diff line number	Diff line change
`@@ -74,7 +74,7 @@ public void initialize(Configuration conf, int reducerId) {`
`74`	`74`	`int numFiles = FileNames.values().length;`
`75`	`75`	`writers = new HDFSCSVWriter[numFiles];`
`76`	`76`	`for( int i = 0; i < numFiles; ++i) {`
`77`		`- writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"), FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|", false);`
	`77`	`+ writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"), FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|", conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));`
`78`	`78`	`}`
`79`	`79`
`80`	`80`	`ArrayList<String> arguments = new ArrayList<String>();`
Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ public void initialize(Configuration conf, int reducerId) {`
`37`	`37`	`int numFiles = FileNames.values().length;`
`38`	`38`	`writers = new HDFSCSVWriter[numFiles];`
`39`	`39`	`for( int i = 0; i < numFiles; ++i) {`
`40`		`- writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|", false);`
	`40`	`+ writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|", conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));`
`41`	`41`	`}`
`42`	`42`
`43`	`43`	`ArrayList<String> arguments = new ArrayList<String>();`
Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,7 @@ public void initialize(Configuration conf, int reducerId) {`
`42`	`42`	`int numFiles = FileNames.values().length;`
`43`	`43`	`writers = new HDFSCSVWriter[numFiles];`
`44`	`44`	`for( int i = 0; i < numFiles; ++i) {`
`45`		`- writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|", false);`
	`45`	`+ writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|", conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));`
`46`	`46`	`}`
`47`	`47`	`arguments = new ArrayList<String>();`
`48`	`48`
Original file line number	Diff line number	Diff line change
`@@ -75,7 +75,7 @@ public void initialize(Configuration conf, int reducerId) {`
`75`	`75`	`int numFiles = FileNames.values().length;`
`76`	`76`	`writers = new HDFSCSVWriter[numFiles];`
`77`	`77`	`for( int i = 0; i < numFiles; ++i) {`
`78`		`- writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|", false);`
	`78`	`+ writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|", conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));`
`79`	`79`	`}`
`80`	`80`
`81`	`81`	`ArrayList<String> arguments = new ArrayList<String>();`
Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ public void initialize(Configuration conf, int reducerId) {`
`48`	`48`	`int numFiles = FileNames.values().length;`
`49`	`49`	`writers = new HDFSCSVWriter[numFiles];`
`50`	`50`	`for( int i = 0; i < numFiles; ++i) {`
`51`		`- writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|",false);`
	`51`	`+ writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|",conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));`
`52`	`52`	`}`
`53`	`53`
`54`	`54`	`ArrayList<String> arguments = new ArrayList<String>();`
Original file line number	Diff line number	Diff line change
`@@ -45,7 +45,7 @@ public void initialize(Configuration conf, int reducerId) {`
`45`	`45`	`int numFiles = FileNames.values().length;`
`46`	`46`	`writers = new HDFSCSVWriter[numFiles];`
`47`	`47`	`for( int i = 0; i < numFiles; ++i) {`
`48`		`- writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|",false);`
	`48`	`+ writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|",conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false));`
`49`	`49`	`}`
`50`	`50`	`arguments = new ArrayList<String>();`
`51`	`51`
Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ public void initialize(Configuration conf, int reducerId) {`
`59`	`59`	`int numFiles = FileNames.values().length;`
`60`	`60`	`writers = new HDFSCSVWriter[numFiles];`
`61`	`61`	`for( int i = 0; i < numFiles; ++i) {`
`62`		`- writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|",false);`
	`62`	`+ writers[i] = new HDFSCSVWriter(conf.get("ldbc.snb.datagen.serializer.socialNetworkDir"),FileNames.values()[i].toString()+"_"+reducerId,conf.getInt("ldbc.snb.datagen.numPartitions",1),conf.getBoolean("ldbc.snb.datagen.serializer.compressed",false),"\|",conf.getBoolean("ldbc.snb.datagen.serializer.endlineSeparator",false) );`
`63`	`63`	`}`
`64`	`64`	`arguments = new ArrayList<String>();`
`65`	`65`