Fixed dates of workAt and studyAt of update_streams

Changed name of aprameter gctdeltaduration

Author: ArnauPrat

src/main/java/ldbc/socialnet/dbgen/generator/MRGenerateUsers.java

@@ -620,7 +620,7 @@ public int runGenerateJob(Configuration conf) throws Exception {
 
         if(conf.getBoolean("updateStreams",false)) {
             OutputStream output = fs.create(new Path(conf.get("outputDir") + "/social_network/updateStream.properties"));
-            output.write(new String("ldbc.snb.interactive.gctdeltaduration:"+conf.get("deltaTime")+"\n").getBytes());
+            output.write(new String("ldbc.snb.interactive.gct_delta_duration:"+conf.get("deltaTime")+"\n").getBytes());
             output.write(new String("ldbc.snb.interactive.min_write_event_start_time:"+min+"\n").getBytes());
             output.write(new String("ldbc.snb.interactive.max_write_event_start_time:"+max+"\n").getBytes());
             output.write(new String("ldbc.snb.interactive.update_interleave:"+(max-min)/numEvents+"\n").getBytes());

src/main/java/ldbc/socialnet/dbgen/serializer/UpdateEventSerializer.java

@@ -394,7 +394,7 @@ public void serialize(UserInfo info) {
                 ArrayList<String> studyAtData = new ArrayList<String>();
                 date.setTimeInMillis(info.extraInfo.getClassYear());
                 studyAtData.add(Long.toString(universityId));
-                studyAtData.add(Long.toString(date.getTime().getTime()));
+                studyAtData.add(DateGenerator.formatYear(date));
                 list.add(formatStringArray(studyAtData,","));
             }
         }
@@ -407,7 +407,7 @@ public void serialize(UserInfo info) {
             date.setTimeInMillis(info.extraInfo.getWorkFrom(companyId));
             ArrayList<String> workAtData = new ArrayList<String>();
             workAtData.add(Long.toString(companyId));
-            workAtData.add(Long.toString(date.getTime().getTime()));
+            workAtData.add(DateGenerator.formatYear(date));
             list.add(formatStringArray(workAtData,","));
         }
         endList();