Skip to content

Commit 495553e

Browse files
committed
Moved AddFriendship event to update forum stream
1 parent 88cee3f commit 495553e

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -426,7 +426,8 @@ public void serialize(Friend friend) {
426426
data.add(Long.toString(friend.getFriendAcc()));
427427
date.setTimeInMillis(friend.getCreatedTime());
428428
data.add(Long.toString(date.getTime().getTime()));
429-
endEvent(Stream.PERSON_STREAM);
429+
//endEvent(Stream.PERSON_STREAM);
430+
endEvent(Stream.FORUM_STREAM);
430431
}
431432
}
432433

0 commit comments

Comments
 (0)