Added serializer for graphalytics without weights

ArnauPrat · ArnauPrat · commit 2bf58369c35c · 2015-05-13T18:39:38.000+02:00
diff --git a/src/main/java/ldbc/snb/datagen/serializer/graphalytics/CSVPersonSerializer.java b/src/main/java/ldbc/snb/datagen/serializer/graphalytics/CSVPersonSerializer.java
@@ -79,7 +79,6 @@ public void initialize(Configuration conf, int reducerId) {
         arguments.clear();
         arguments.add("Person.id");
         arguments.add("Person.id");
-        arguments.add("Weight");
         writers[FileNames.PERSON_KNOWS_PERSON.ordinal()].writeEntry(arguments);
 
     }
@@ -109,7 +108,6 @@ protected void serialize(Person p, Knows knows) {
         ArrayList<String> arguments = new ArrayList<String>();
         arguments.add(Long.toString(p.accountId()));
         arguments.add(Long.toString(knows.to().accountId()));
-        arguments.add(Float.toString(knows.weight()));
         writers[FileNames.PERSON_KNOWS_PERSON.ordinal()].writeEntry(arguments);
     }
 

Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,6 @@ public void initialize(Configuration conf, int reducerId) {`
`79`	`79`	`arguments.clear();`
`80`	`80`	`arguments.add("Person.id");`
`81`	`81`	`arguments.add("Person.id");`
`82`		`- arguments.add("Weight");`
`83`	`82`	`writers[FileNames.PERSON_KNOWS_PERSON.ordinal()].writeEntry(arguments);`
`84`	`83`
`85`	`84`	`}`
`@@ -109,7 +108,6 @@ protected void serialize(Person p, Knows knows) {`
`109`	`108`	`ArrayList<String> arguments = new ArrayList<String>();`
`110`	`109`	`arguments.add(Long.toString(p.accountId()));`
`111`	`110`	`arguments.add(Long.toString(knows.to().accountId()));`
`112`		`- arguments.add(Float.toString(knows.weight()));`
`113`	`111`	`writers[FileNames.PERSON_KNOWS_PERSON.ordinal()].writeEntry(arguments);`
`114`	`112`	`}`
`115`	`113`