Skip to content

Commit db1595a

Browse files
committed
fixed package of pgx serializer
1 parent 749c234 commit db1595a

File tree

5 files changed

+2
-537
lines changed

5 files changed

+2
-537
lines changed

src/main/java/ldbc/snb/datagen/serializer/graphalytics/pgx/CSVPersonSerializer.java

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@
3636
*/
3737

3838

39-
package ldbc.snb.datagen.serializer.graphalytics;
39+
package ldbc.snb.datagen.serializer.graphalytics.pgx;
4040

4141
import ldbc.snb.datagen.objects.Knows;
4242
import ldbc.snb.datagen.objects.Person;
@@ -73,15 +73,8 @@ public void initialize(Configuration conf, int reducerId) {
7373
int numFiles = FileNames.values().length;
7474
writers = new HDFSCSVWriter[numFiles];
7575
for( int i = 0; i < numFiles; ++i) {
76-
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+
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));
7777
}
78-
79-
ArrayList<String> arguments = new ArrayList<String>();
80-
arguments.clear();
81-
arguments.add("Person.id");
82-
arguments.add("Person.id");
83-
writers[FileNames.PERSON_KNOWS_PERSON.ordinal()].writeEntry(arguments);
84-
8578
}
8679

8780
@Override

src/main/resources/distributions/dblp.dat

Lines changed: 0 additions & 199 deletions
This file was deleted.

0 commit comments

Comments
 (0)