differentiate between forward and backward read stats

twitter-archive · Jan 19, 2012 · 7396220 · 7396220
1 parent 8730216
commit 7396220
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/main/scala/com/twitter/flockdb/queries/SelectCompiler.scala b/src/main/scala/com/twitter/flockdb/queries/SelectCompiler.scala
@@ -51,11 +51,14 @@ class SelectCompiler(forwardingManager: ForwardingManager, intersectionConfig: c
     if (items != 1) throw new InvalidQueryException("Left " + items + " items on the stack instaed of 1")
 
     var stack = new mutable.Stack[QueryTree]
-    val graphIds = new mutable.HashSet[Int]
+    val graphIds = new mutable.HashSet[String]
     for (op <- program) op.operationType match {
       case SelectOperationType.SimpleQuery =>
         val term = op.term.get
-        graphIds += term.graphId
+
+        // denote n for a backwards query
+        graphIds += (if (term.isForward) "" else "n") + term.graphId
+
         val shard = forwardingManager.find(term.sourceId, term.graphId, Direction(term.isForward))
         val states = if (term.states.isEmpty) List(State.Normal) else term.states
         val query = if (term.destinationIds.isDefined) {