File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
src/main/java/ldbc/snb/datagen Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change 50
50
import java .util .ArrayList ;
51
51
import java .util .Iterator ;
52
52
53
- public class CSVPersonSerializer extends PersonSerializer {
53
+ public class CSVPersonSerializerWithWeights extends PersonSerializer {
54
54
55
55
private HDFSCSVWriter [] writers ;
56
56
@@ -67,7 +67,7 @@ public String toString() {
67
67
}
68
68
}
69
69
70
- public CSVPersonSerializer () {
70
+ public CSVPersonSerializerWithWeights () {
71
71
}
72
72
73
73
public void initialize (Configuration conf , int reducerId ) {
Original file line number Diff line number Diff line change @@ -32,7 +32,7 @@ public static Configuration initialize() {
32
32
conf .set ("ldbc.snb.datagen.generator.startYear" ,"2010" );
33
33
conf .set ("ldbc.snb.datagen.generator.numYears" ,"3" );
34
34
conf .set ("ldbc.snb.datagen.generator.numThreads" , Integer .toString (1 ));
35
- conf .set ("ldbc.snb.datagen.serializer.personSerializer" , "ldbc.snb.datagen.serializer.snb.interactive.CSVPersonSerializer " );
35
+ conf .set ("ldbc.snb.datagen.serializer.personSerializer" , "ldbc.snb.datagen.serializer.snb.interactive.CSVPersonSerializerWithWeights " );
36
36
conf .set ("ldbc.snb.datagen.serializer.invariantSerializer" , "ldbc.snb.datagen.serializer.snb.interactive.CSVInvariantSerializer" );
37
37
conf .set ("ldbc.snb.datagen.serializer.personActivitySerializer" , "ldbc.snb.datagen.serializer.snb.interactive.CSVPersonActivitySerializer" );
38
38
conf .set ("ldbc.snb.datagen.generator.distribution.degreeDistribution" , "ldbc.snb.datagen.generator.distribution.FacebookDegreeDistribution" );
You can’t perform that action at this time.
0 commit comments