Reenabled removal of temporary update streams files

Author: ArnauPrat

src/main/java/ldbc/snb/datagen/generator/LDBCDatagen.java

@@ -179,13 +179,13 @@ public int runGenerateJob(Configuration conf) throws Exception {
             HadoopUpdateStreamSorterAndSerializer updateSorterAndSerializer = new HadoopUpdateStreamSorterAndSerializer(conf);
             updateSorterAndSerializer.run(personStreamsFileNames, "person");
             updateSorterAndSerializer.run(forumStreamsFileNames, "forum");
-            /*for(String file : personStreamsFileNames) {
+            for(String file : personStreamsFileNames) {
                 fs.delete(new Path(file), true);
             }
 
             for(String file : forumStreamsFileNames) {
                 fs.delete(new Path(file), true);
-            }*/
+            }
 
             /*for( int i = 0; i < DatagenParams.numThreads; ++i) {
                 int numPartitions = conf.getInt("ldbc.snb.datagen.serializer.numUpdatePartitions", 1);

src/main/java/ldbc/snb/datagen/hadoop/HadoopUpdateStreamSorterAndSerializer.java

@@ -28,9 +28,6 @@ public class HadoopUpdateStreamSorterAndSerializer {
 
 	public static class HadoopUpdateStreamSorterAndSerializerReducer  extends Reducer<UpdateEventKey, Text, UpdateEventKey, Text> {
 
-		private int reducerId;                          /** The id of the reducer.**/
-		private PersonSerializer personSerializer_;   /** The person serializer **/
-		private UpdateEventSerializer updateSerializer_;
 		private boolean compressed = false;
 		private Configuration conf;
 		private String streamType;