Skip to content
This repository has been archived by the owner on Sep 18, 2021. It is now read-only.

Commit

Permalink
typo
Browse files Browse the repository at this point in the history
  • Loading branch information
eaceaser committed Dec 8, 2010
1 parent a34a145 commit f10315a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/main/scala/com/twitter/flockdb/shards/SqlShard.scala
Expand Up @@ -327,7 +327,7 @@ class SqlShard(private val queryEvaluator: QueryEvaluator, val shardInfo: shards
def intersectEdges(sourceId: Long, states: Seq[State], destinationIds: Seq[Long]) = {
if (destinationIds.size == 0) Nil else {
val (rv, msec) = Stats.duration {
queryEvaluator.select(SelectIntersection"SELECT * FROM " + tablePrefix + "_edges WHERE source_id = ? AND state IN (?) AND destination_id IN (?) ORDER BY destination_id DESC",
queryEvaluator.select(SelectIntersection, "SELECT * FROM " + tablePrefix + "_edges WHERE source_id = ? AND state IN (?) AND destination_id IN (?) ORDER BY destination_id DESC",
List(sourceId, states.map(_.id).toList, destinationIds): _*) { row =>
makeEdge(row)
}
Expand Down

0 comments on commit f10315a

Please sign in to comment.