Mirrors
/
the-algorithm
mirror of https://github.com/twitter/the-algorithm.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge 6ee0d2b7ac into 72eda9a24f

This commit is contained in:
Erik Innocent 2023-07-17 21:37:20 -05:00 committed by GitHub
parent 72eda9a24f 6ee0d2b7ac
commit 6654f8e9f7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 15 deletions
Show Stats Download Patch File Download Diff File 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 =
rightEdgeMap.get(featureType.rightEdgeType).flatMap(_.get(candidateId))
if (leftNeighborsOpt.isEmpty && rightNeighborsOpt.isEmpty) {
EmptyWorkerIntersectionValue
} else if (rightNeighborsOpt.isEmpty) {
EmptyWorkerIntersectionValue.copy(
leftNodeDegree = computeArraySize(leftNeighborsOpt.get)
)
} else if (leftNeighborsOpt.isEmpty) {
EmptyWorkerIntersectionValue.copy(
rightNodeDegree = computeArraySize(rightNeighborsOpt.get)
)
} else {
IntersectionValueCalculator(
leftNeighborsOpt.get,
rightNeighborsOpt.get,
request.intersectionIdLimit)
(leftNeighborsOpt, rightNeighborsOpt) match {
case (Some(leftNeighbors), None) =>
EmptyWorkerIntersectionValue.copy(
leftNodeDegree = computeArraySize(leftNeighbors)
)
case (None, Some(rightNeighbors)) =>
EmptyWorkerIntersectionValue.copy(
rightNodeDegree = computeArraySize(rightNeighbors)
)
case (Some(leftNeighbors), Some(rightNeighbors)) =>
IntersectionValueCalculator(
leftNeighbors,
rightNeighbors,
request.intersectionIdLimit
)
case _ =>
EmptyWorkerIntersectionValue
}
}
}