@@ -97,14 +97,14 @@ public int runGenerateJob(Configuration conf) throws Exception {
97
97
printProgress ("Starting: Person generation" );
98
98
long startPerson = System .currentTimeMillis ();
99
99
HadoopPersonGenerator personGenerator = new HadoopPersonGenerator (conf );
100
- personGenerator .run (hadoopPrefix + "/persons" , "ldbc.snb.datagen.hadoop.utiljobs .keychanger.UniversityKeySetter" );
100
+ personGenerator .run (hadoopPrefix + "/persons" , "ldbc.snb.datagen.hadoop.miscjob .keychanger.UniversityKeySetter" );
101
101
long endPerson = System .currentTimeMillis ();
102
102
103
103
printProgress ("Creating university location correlated edges" );
104
104
long startUniversity = System .currentTimeMillis ();
105
105
HadoopKnowsGenerator knowsGenerator = new HadoopKnowsGenerator (conf ,
106
- "ldbc.snb.datagen.hadoop.utiljobs .keychanger.UniversityKeySetter" ,
107
- "ldbc.snb.datagen.hadoop.utiljobs .keychanger.RandomKeySetter" ,
106
+ "ldbc.snb.datagen.hadoop.miscjob .keychanger.UniversityKeySetter" ,
107
+ "ldbc.snb.datagen.hadoop.miscjob .keychanger.RandomKeySetter" ,
108
108
percentages ,
109
109
0 ,
110
110
conf .get ("ldbc.snb.datagen.generator.knowsGenerator" ));
@@ -117,8 +117,8 @@ public int runGenerateJob(Configuration conf) throws Exception {
117
117
long startInterest = System .currentTimeMillis ();
118
118
119
119
knowsGenerator = new HadoopKnowsGenerator (conf ,
120
- "ldbc.snb.datagen.hadoop.utiljobs .keychanger.InterestKeySetter" ,
121
- "ldbc.snb.datagen.hadoop.utiljobs .keychanger.RandomKeySetter" ,
120
+ "ldbc.snb.datagen.hadoop.miscjob .keychanger.InterestKeySetter" ,
121
+ "ldbc.snb.datagen.hadoop.miscjob .keychanger.RandomKeySetter" ,
122
122
percentages ,
123
123
1 ,
124
124
conf .get ("ldbc.snb.datagen.generator.knowsGenerator" ));
@@ -131,8 +131,8 @@ public int runGenerateJob(Configuration conf) throws Exception {
131
131
long startRandom = System .currentTimeMillis ();
132
132
133
133
knowsGenerator = new HadoopKnowsGenerator (conf ,
134
- "ldbc.snb.datagen.hadoop.utiljobs .keychanger.RandomKeySetter" ,
135
- "ldbc.snb.datagen.hadoop.utiljobs .keychanger.RandomKeySetter" ,
134
+ "ldbc.snb.datagen.hadoop.miscjob .keychanger.RandomKeySetter" ,
135
+ "ldbc.snb.datagen.hadoop.miscjob .keychanger.RandomKeySetter" ,
136
136
percentages ,
137
137
2 ,
138
138
"ldbc.snb.datagen.generator.generators.knowsgenerators.RandomKnowsGenerator" );
@@ -148,7 +148,7 @@ public int runGenerateJob(Configuration conf) throws Exception {
148
148
edgeFileNames .add (hadoopPrefix + "/interestEdges" );
149
149
edgeFileNames .add (hadoopPrefix + "/randomEdges" );
150
150
long startMerge = System .currentTimeMillis ();
151
- HadoopMergeFriendshipFiles merger = new HadoopMergeFriendshipFiles (conf , "ldbc.snb.datagen.hadoop.utiljobs .keychanger.RandomKeySetter" );
151
+ HadoopMergeFriendshipFiles merger = new HadoopMergeFriendshipFiles (conf , "ldbc.snb.datagen.hadoop.miscjob .keychanger.RandomKeySetter" );
152
152
merger .run (hadoopPrefix + "/mergedPersons" , edgeFileNames );
153
153
long endMerge = System .currentTimeMillis ();
154
154
0 commit comments