Skip to content

Commit 149445e

Browse files
committed
fix person serialization issues
1 parent d3147da commit 149445e

File tree

2 files changed

+4
-8
lines changed

2 files changed

+4
-8
lines changed

src/main/scala/ldbc/snb/datagen/generator/serializers/PersonOutputStream.scala

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ class PersonOutputStream(
1616
personWorkAtCompanyStream: RecordOutputStream[raw.PersonWorkAtCompany]
1717
) extends RecordOutputStream[Person] {
1818

19-
private def getGender(gender: Int): String = if (gender == 0) "male" else "female"
19+
private def getGender(gender: Int): String = if (gender == 0) "female" else "male"
2020

2121
private def getLanguages(languages: util.List[Integer]): Seq[String] = {
2222
languages.asScala.map(x => Dictionaries.languages.getLanguageName(x))
@@ -60,7 +60,6 @@ class PersonOutputStream(
6060
val personStudyAtUniversity = raw.PersonStudyAtUniversity(
6161
person.getCreationDate,
6262
person.getDeletionDate,
63-
person.isExplicitlyDeleted,
6463
person.getAccountId,
6564
universityId,
6665
person.getClassYear.toInt
@@ -72,7 +71,6 @@ class PersonOutputStream(
7271
val personWorkAtCompany = raw.PersonWorkAtCompany(
7372
person.getCreationDate,
7473
person.getDeletionDate,
75-
person.isExplicitlyDeleted,
7674
person.getAccountId,
7775
companyId,
7876
person.getCompanies.get(companyId).toInt
@@ -85,9 +83,9 @@ class PersonOutputStream(
8583
for (know <- knows.iterator().asScala) {
8684
if (person.getAccountId < know.to.getAccountId) {
8785
val personKnowsPerson = raw.PersonKnowsPerson(
88-
person.getCreationDate,
89-
person.getDeletionDate,
90-
person.isExplicitlyDeleted,
86+
know.getCreationDate,
87+
know.getDeletionDate,
88+
know.isExplicitlyDeleted,
9189
person.getAccountId,
9290
know.to().getAccountId
9391
)

src/main/scala/ldbc/snb/datagen/model/raw.scala

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,6 @@ object raw {
4141
case class PersonStudyAtUniversity(
4242
creationDate: Long,
4343
deletionDate: Long,
44-
explicitlyDeleted: Boolean,
4544
PersonId: Long,
4645
UniversityId: Long,
4746
classYear: Int
@@ -50,7 +49,6 @@ object raw {
5049
case class PersonWorkAtCompany(
5150
creationDate: Long,
5251
deletionDate: Long,
53-
explicitlyDeleted: Boolean,
5452
PersonId: Long,
5553
CompanyId: Long,
5654
workFrom: Int

0 commit comments

Comments
 (0)