File tree Expand file tree Collapse file tree 2 files changed +8
-2
lines changed
src/main/java/ldbc/snb/datagen Expand file tree Collapse file tree 2 files changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -153,8 +153,13 @@ public int runGenerateJob(Configuration conf) throws Exception {
153
153
154
154
printProgress ("Serializing persons" );
155
155
long startPersonSerializing = System .currentTimeMillis ();
156
- HadoopPersonSerializer serializer = new HadoopPersonSerializer (conf );
157
- serializer .run (hadoopPrefix + "/mergedPersons" );
156
+ if (conf .getBoolean ("ldbc.snb.datagen.serializer.persons.sort" , true )) {
157
+ HadoopPersonSortAndSerializer serializer = new HadoopPersonSortAndSerializer (conf );
158
+ serializer .run (hadoopPrefix + "/mergedPersons" );
159
+ } else {
160
+ HadoopDynamicPersonSerializer serializer = new HadoopDynamicPersonSerializer (conf );
161
+ serializer .run (hadoopPrefix + "/mergedPersons" );
162
+ }
158
163
long endPersonSerializing = System .currentTimeMillis ();
159
164
160
165
long startPersonActivity = System .currentTimeMillis ();
Original file line number Diff line number Diff line change @@ -88,6 +88,7 @@ public static Configuration initialize() throws Exception {
88
88
conf .set ("ldbc.snb.datagen.generator.person.similarity" , "ldbc.snb.datagen.entities.dynamic.person.similarity.GeoDistanceSimilarity" );
89
89
conf .set ("ldbc.snb.datagen.parametergenerator.python" , "python" );
90
90
conf .set ("ldbc.snb.datagen.parametergenerator.parameters" , "true" );
91
+ conf .set ("ldbc.snb.datagen.serializer.persons.sort" , "true" );
91
92
92
93
/** Loading predefined Scale Factors **/
93
94
You can’t perform that action at this time.
0 commit comments