private def readOutEdges()

in cassovary-core/src/main/scala/com/twitter/cassovary/graph/ArrayBasedDirectedGraph.scala [200:219]

• 19 lines of code
• 3 McCabe index (conditional complexity)

    private def readOutEdges(iterator: Iterator[NodeIdEdgesMaxId]):
    Future[GraphInfo[Node]] = futurePool {
      Stat.time(statsReceiver.stat("graph_load_read_out_edge_from_dump_files")) {
        val nodesWithEdges = new mutable.ArrayBuffer[Node]
        var newMaxId = 0
        var numEdges = 0L

        iterator foreach { item =>
          val id = item.id
          newMaxId = newMaxId max item.maxId
          numEdges += item.edges.length
          val edges = if (neighborsSortingStrategy == SortWhileReading) item.edges.sorted else item.edges
          val newNode = ArrayBasedDirectedNode(id, edges, storedGraphDir,
            neighborsSortingStrategy != LeaveUnsorted)
          nodesWithEdges += newNode
        }
        GraphInfo[Node](nodesWithEdges, maxNodeId = newMaxId, numNodes = nodesWithEdges.length,
          numEdges = numEdges)
      }
    }