Mirrors/the-algorithm
2
0
Fork 0
mirror of https://github.com/twitter/the-algorithm.git synced 2025-01-02 23:51:53 +01:00
Code Issues Packages Projects Releases Wiki Activity

Compare commits

base: Mirrors:25636f351e9309b409bc93218645802517bca283
Branches Tags
Mirrors:main
...
compare: Mirrors:0348c496263a43f1ffd16b59df25a639effea7e6
Branches Tags
Mirrors:main

2 Commits
25636f351e ... 0348c49626

Author SHA1 Message Date
Adam LaCombe
0348c49626
Merge e13c4a9233 into fb54d8b549 2023-05-22 17:41:46 -05:00
Adam LaCombe
e13c4a9233 fix typo magicRecsNotfication > magicRecsNotification 2023-03-31 22:53:03 +00:00
4 changed files with 5 additions and 5 deletions
Show Stats Expand all files Collapse all files

2
src/scala/com/twitter/simclusters_v2/scalding/embedding/common/ExternalDataSources.scala
View File

@ -492,7 +492,7 @@ object ExternalDataSources {
}
}
def magicRecsNotficationOpenOrClickEventsSource(
def magicRecsNotificationOpenOrClickEventsSource(
implicit dateRange: DateRange
): TypedPipe[MagicRecsNotificationLite] = {
DAL

2
src/scala/com/twitter/simclusters_v2/scalding/multi_type_graph/assemble_multi_type_graph/AssembleMultiTypeGraph.scala
View File

@ -491,7 +491,7 @@ object AssembleMultiTypeGraph {
// user-MRNotifOpenOrClick events from last 7 days
val userMRNotifOpenOrClickEvents: TypedPipe[MagicRecsNotificationLite] =
ExternalDataSources.magicRecsNotficationOpenOrClickEventsSource(dateRange =
ExternalDataSources.magicRecsNotificationOpenOrClickEventsSource(dateRange =
DateRange(dateRange.end - Days(7), dateRange.end))
// user-searchQuery strings from last 7 days

4
src/scala/com/twitter/simclusters_v2/scio/common/ExternalDataSources.scala
View File

@ -236,13 +236,13 @@ object ExternalDataSources {
}
}
def magicRecsNotficationOpenOrClickEventsSource(
def magicRecsNotificationOpenOrClickEventsSource(
interval: Interval
)(
implicit sc: ScioContext
): SCollection[MagicRecsNotificationLite] = {
sc.customInput(
"ReadMagicRecsNotficationOpenOrClickEventsSource",
"ReadMagicRecsNotificationOpenOrClickEventsSource",
DAL
.read(MagicrecsNotificationLite1DayLagScalaDataset, interval, DAL.Environment.Prod))
.filter { entry =>

2
src/scala/com/twitter/simclusters_v2/scio/multi_type_graph/assemble_multi_type_graph/AssembleMultiTypeGraphScioBaseApp.scala
View File

@ -423,7 +423,7 @@ trait AssembleMultiTypeGraphScioBaseApp extends ScioBeamJob[DateRangeOptions] {
// user-MRNotifOpenOrClick events from last 7 days
val userMRNotifOpenOrClickEvents =
ExternalDataSources.magicRecsNotficationOpenOrClickEventsSource(interval_7days)
ExternalDataSources.magicRecsNotificationOpenOrClickEventsSource(interval_7days)
// user-searchQuery strings from last 7 days
val userSearchQueryEdges =