fixed error with update stream consistency

Author: ArnauPrat

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

@@ -234,7 +234,7 @@ public Comment createComment(RandomGeneratorFarm randomFarm, long commentId, Pos
                                        textSize,
                                        creationDate,
                                        friend.getFriendAcc(),
-                                       friend.fromCreationDate,
+                                       friend.toCreationDate,
                                        post.getGroupId(),
                                        tags,
                                        ipAddDic.getIP(randomFarm.get(RandomGeneratorFarm.Aspect.IP), randomFarm.get(RandomGeneratorFarm.Aspect.DIFF_IP), randomFarm.get(RandomGeneratorFarm.Aspect.DIFF_IP_FOR_TRAVELER),friend.getSourceIp(), friend.isFrequentChange(), creationDate),

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

@@ -115,6 +115,7 @@ public Group createAlbum(RandomGeneratorFarm randomFarm, long groupId, ReducedUs
 	                    group.getCreatedDate(), friends[i]);
                 if( memberShip != null ) {
                     memberShip.setGroupId(group.getGroupId());
+                    memberShip.userCreationDate = friends[i].toCreationDate;
                     group.addMember(memberShip);
                 }
 	        }
@@ -134,6 +135,7 @@ public GroupMemberShip createGroupMember(Random random, long userId, long groupC
 		memberShip.setFrequentChange(friend.isFrequentChange());
 		memberShip.setHaveSmartPhone(friend.isHaveSmartPhone());
         memberShip.setLargePoster(friend.isLargePoster());
+        memberShip.userCreationDate = friend.toCreationDate;
 		return memberShip;
 	}
 
@@ -150,6 +152,7 @@ public GroupMemberShip createGroupMember(Random random, long userId, long groupC
         memberShip.setFrequentChange(user.isFrequentChange());
         memberShip.setHaveSmartPhone(user.isHaveSmartPhone());
         memberShip.setLargePoster(user.isLargePoster());
+        memberShip.userCreationDate = user.getCreationDate();
         return memberShip;
     }
 }

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

@@ -1515,14 +1515,16 @@ private void createFriendShip(ReducedUserProfile user1, ReducedUserProfile user2
                 createdTime = dateTimeGenerator.randomFriendReapprovedDate(randomFarm.get(RandomGeneratorFarm.Aspect.DATE),declinedTime);
             }
         }
-        createdTime = createdTime - user1.getCreationDate() >= deltaTime ? createdTime : createdTime + (deltaTime - (createdTime - user1.getCreationDate() ));
-        createdTime = createdTime - user2.getCreationDate() >= deltaTime ? createdTime : createdTime + (deltaTime - (createdTime - user2.getCreationDate() ));
-        if( createdTime <= dateTimeGenerator.getEndDateTime() ) {
-            user2.addNewFriend(new Friend(user2, user1, requestedTime, declinedTime,
-                    createdTime, pass, initiator));
-            user1.addNewFriend(new Friend(user1, user2, requestedTime, declinedTime,
-                    createdTime, pass, initiator));
-            friendshipNum++;
+        if(createdTime != -1) {
+            createdTime = createdTime - user1.getCreationDate() >= deltaTime ? createdTime : createdTime + deltaTime;
+            createdTime = createdTime - user2.getCreationDate() >= deltaTime ? createdTime : createdTime + deltaTime;
+            if (createdTime <= dateTimeGenerator.getEndDateTime()) {
+                user2.addNewFriend(new Friend(user2, user1, requestedTime, declinedTime,
+                        createdTime, pass, initiator));
+                user1.addNewFriend(new Friend(user1, user2, requestedTime, declinedTime,
+                        createdTime, pass, initiator));
+                friendshipNum++;
+            }
         }
     }
 
@@ -1580,17 +1582,17 @@ private void writeFactorTable(){
             	ReducedUserProfile.Counts count = c.getValue();
             	// correct the group counts
             	//count.numberOfGroups += count.numberOfFriends;
-            	StringBuffer strbuf = new StringBuffer();
-		strbuf.append(c.getKey()); strbuf.append(",");
-		String name = medianFirstName.get(c.getKey());
-		strbuf.append(name); strbuf.append(",");
-            	strbuf.append(count.numberOfFriends); 		strbuf.append(",");
-            	strbuf.append(count.numberOfPosts); 		strbuf.append(",");
-            	strbuf.append(count.numberOfLikes); 		strbuf.append(",");
-            	strbuf.append(count.numberOfTagsOfPosts); 	strbuf.append(",");
-            	strbuf.append(count.numberOfGroups); 		strbuf.append(",");
-            	strbuf.append(count.numberOfWorkPlaces); 	strbuf.append(",");
-            	strbuf.append(count.numberOfPostReplies); 	strbuf.append(",");
+                StringBuffer strbuf = new StringBuffer();
+                strbuf.append(c.getKey()); strbuf.append(",");
+                String name = medianFirstName.get(c.getKey());
+                strbuf.append(name); strbuf.append(",");
+                strbuf.append(count.numberOfFriends); 		strbuf.append(",");
+                strbuf.append(count.numberOfPosts); 		strbuf.append(",");
+                strbuf.append(count.numberOfLikes); 		strbuf.append(",");
+                strbuf.append(count.numberOfTagsOfPosts); 	strbuf.append(",");
+                strbuf.append(count.numberOfGroups); 		strbuf.append(",");
+                strbuf.append(count.numberOfWorkPlaces); 	strbuf.append(",");
+                strbuf.append(count.numberOfPostReplies); 	strbuf.append(",");
 
             	int numBuckets = count.numberOfPostsPerMonth.length;
             	for (int i = 0; i < numBuckets; i++){

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

@@ -400,7 +400,6 @@ public void export(Group group, long dependantDate) {
         		if (bucket < factorTable.get(memberships[i].getUserId()).numberOfGroupsPerMonth.length){
         			factorTable.get(memberships[i].getUserId()).numberOfGroupsPerMonth[bucket]++;
         		}
-
                 staticSerializer.serialize(memberships[i]);
             } else {
                 updateStreamSerializer.setCurrentDependantDate(memberships[i].userCreationDate);