Mirrors/the-algorithm
2
0
Fork 0
mirror of https://github.com/twitter/the-algorithm.git synced 2024-12-22 18:21:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

Compare commits

base: Mirrors:6654f8e9f745e958a70e047066b0e660be150db7
Branches Tags
Mirrors:main
...
compare: Mirrors:6cbdbc963241fbd5dce71455b48fb0a6554c21d0
Branches Tags
Mirrors:main

2 Commits
6654f8e9f7 ... 6cbdbc9632

Author SHA1 Message Date
Erik Innocent
6cbdbc9632
Merge 6ee0d2b7ac into fb54d8b549 2023-05-22 15:35:59 -07:00
Erik Innocent
6ee0d2b7ac Avoid raw get 2023-04-07 15:27:46 -07:00
1 changed files with 17 additions and 15 deletions
Show Stats Expand all files Collapse all files

32
graph-feature-service/src/main/scala/com/twitter/graph_feature_service/worker/handlers/WorkerGetIntersectionHandler.scala
View File

@ -75,21 +75,23 @@ class WorkerGetIntersectionHandler @Inject() (
val rightNeighborsOpt = val rightNeighborsOpt =
rightEdgeMap.get(featureType.rightEdgeType).flatMap(_.get(candidateId)) rightEdgeMap.get(featureType.rightEdgeType).flatMap(_.get(candidateId))
if (leftNeighborsOpt.isEmpty && rightNeighborsOpt.isEmpty) { (leftNeighborsOpt, rightNeighborsOpt) match {
EmptyWorkerIntersectionValue case (Some(leftNeighbors), None) =>
} else if (rightNeighborsOpt.isEmpty) { EmptyWorkerIntersectionValue.copy(
EmptyWorkerIntersectionValue.copy( leftNodeDegree = computeArraySize(leftNeighbors)
leftNodeDegree = computeArraySize(leftNeighborsOpt.get) )
) case (None, Some(rightNeighbors)) =>
} else if (leftNeighborsOpt.isEmpty) { EmptyWorkerIntersectionValue.copy(
EmptyWorkerIntersectionValue.copy( rightNodeDegree = computeArraySize(rightNeighbors)
rightNodeDegree = computeArraySize(rightNeighborsOpt.get) )
) case (Some(leftNeighbors), Some(rightNeighbors)) =>
} else { IntersectionValueCalculator(
IntersectionValueCalculator( leftNeighbors,
leftNeighborsOpt.get, rightNeighbors,
rightNeighborsOpt.get, request.intersectionIdLimit
request.intersectionIdLimit) )
case _ =>
EmptyWorkerIntersectionValue
} }
} }
} }