@@ -140,30 +140,14 @@ public HadoopKnowsGenerator(Configuration conf, String preKeySetterName, String
140
140
}
141
141
142
142
public void run (String inputFileName , String outputFileName ) throws Exception {
143
-
144
-
145
143
FileSystem fs = FileSystem .get (conf );
146
144
147
- /*String keyChangedFileName = inputFileName;
148
- if(preKeySetterName != null) {
149
- System.out.println("Changing key of persons");
150
- long start = System.currentTimeMillis();
151
- keyChangedFileName = conf.get("ldbc.snb.datagen.serializer.hadoopDir") + "/key_changed";
152
- HadoopFileKeyChanger keyChanger = new HadoopFileKeyChanger(conf, TupleKey.class, Person.class, preKeySetterName);
153
- keyChanger.run(inputFileName, keyChangedFileName);
154
- System.out.println("... Time to change keys: "+ (System.currentTimeMillis() - start)+" ms");
155
- }
156
- */
157
-
158
145
System .out .println ("Ranking persons" );
159
146
long start = System .currentTimeMillis ();
160
147
String rankedFileName = conf .get ("ldbc.snb.datagen.serializer.hadoopDir" ) + "/ranked" ;
161
148
HadoopFileRanker hadoopFileRanker = new HadoopFileRanker (conf , TupleKey .class , Person .class , preKeySetterName );
162
149
hadoopFileRanker .run (inputFileName , rankedFileName );
163
- /* if(preKeySetterName != null ) {
164
- fs.delete(new Path(keyChangedFileName), true);
165
- }
166
- */
150
+
167
151
System .out .println ("... Time to rank persons: " + (System .currentTimeMillis () - start ) + " ms" );
168
152
169
153
conf .setInt ("stepIndex" , step_index );
0 commit comments