Skip to content

Commit 668f1bd

Browse files
authored
Merge pull request #403 from ldbc/person-has-interest-attrs
Rename HasInterestTag properties
2 parents 8461db7 + 8f302f6 commit 668f1bd

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

src/main/scala/ldbc/snb/datagen/factors/FactorGenerationStage.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -315,9 +315,9 @@ object FactorGenerationStage extends DatagenStage with Logging {
315315
},
316316
"tagNumPersons" -> Factor(PersonHasInterestTagType, TagType) { case Seq(interest, tag) =>
317317
frequency(
318-
interest.join(tag.as("Tag"), $"Tag.id" === $"interestId"),
319-
value = $"personId",
320-
by = Seq($"interestId", $"Tag.name")
318+
interest.join(tag.as("Tag"), $"Tag.id" === $"TagId"),
319+
value = $"PersonId",
320+
by = Seq($"Tag.id", $"Tag.name")
321321
)
322322
},
323323
"tagClassNumTags" -> Factor(TagClassType, TagType) { case Seq(tagClass, tag) =>

src/main/scala/ldbc/snb/datagen/io/raw/csv/CsvRowEncoderInstances.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,8 +46,8 @@ trait CsvRowEncoderInstances {
4646
override def row(t: PersonHasInterestTag): Seq[String] = Array(
4747
t.creationDate.toString,
4848
t.deletionDate.toString,
49-
t.personId.toString,
50-
t.interestId.toString
49+
t.`PersonId`.toString,
50+
t.`TagId`.toString
5151
)
5252
}
5353

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@ object raw {
2626
case class PersonHasInterestTag(
2727
creationDate: Long,
2828
deletionDate: Long,
29-
personId: Long,
30-
interestId: Int
29+
`PersonId`: Long,
30+
`TagId`: Int
3131
) extends RawEntity
3232

3333
case class PersonKnowsPerson(

0 commit comments

Comments
 (0)