@@ -82,9 +82,9 @@ object FactorGenerationStage extends DatagenStage with Logging {
82
82
personKnowsPerson
83
83
.alias(" Knows" )
84
84
.join(persons.cache().as(" Person1" ), $" Person1.id" === $" Knows.Person1Id" )
85
- .join(cities.cache().as(" City1" ), $" City1.id" === " Person1.LocationCityId" )
85
+ .join(cities.cache().as(" City1" ), $" City1.id" === $ " Person1.LocationCityId" )
86
86
.join(persons.as(" Person2" ), $" Person2.id" === $" Knows.Person2Id" )
87
- .join(cities.as(" City2" ), $" City2.id" === " Person2.LocationCityId" )
87
+ .join(cities.as(" City2" ), $" City2.id" === $ " Person2.LocationCityId" )
88
88
.where($" City1.id" < $" City2.id" ),
89
89
value = $" *" ,
90
90
by = Seq ($" City1.id" , $" City2.id" , $" City1.name" , $" City2.name" )
@@ -104,11 +104,11 @@ object FactorGenerationStage extends DatagenStage with Logging {
104
104
personKnowsPerson
105
105
.alias(" Knows" )
106
106
.join(persons.cache().as(" Person1" ), $" Person1.id" === $" Knows.Person1Id" )
107
- .join(cities.cache().as(" City1" ), $" City1.id" === " Person1.LocationCityId" )
108
- .join(countries.cache().as(" Country1" ), $" Country1.id" === " City1.PartOfPlaceId" )
107
+ .join(cities.cache().as(" City1" ), $" City1.id" === $ " Person1.LocationCityId" )
108
+ .join(countries.cache().as(" Country1" ), $" Country1.id" === $ " City1.PartOfPlaceId" )
109
109
.join(persons.as(" Person2" ), $" Person2.id" === $" Knows.Person2Id" )
110
- .join(cities.as(" City2" ), $" City2.id" === " Person2.LocationCityId" )
111
- .join(countries.as(" Country2" ), $" Country2.id" === " City2.PartOfPlaceId" )
110
+ .join(cities.as(" City2" ), $" City2.id" === $ " Person2.LocationCityId" )
111
+ .join(countries.as(" Country2" ), $" Country2.id" === $ " City2.PartOfPlaceId" )
112
112
.where($" Country1.id" < $" Country2.id" ),
113
113
value = $" *" ,
114
114
by = Seq ($" Country1.id" , $" Country2.id" , $" Country1.name" , $" Country2.name" )
0 commit comments