private def split()

in cassovary-core/src/main/scala/com/twitter/cassovary/graph/distributed/GraphFilesSplitter.scala [87:98]

• 12 lines of code
• 5 McCabe index (conditional complexity)

  private def split(it: Iterator[NodeIdEdgesMaxId],
      instanceWriters: Array[BufferedWriter]): Future[Unit] = futurePool {
    it foreach { origNode =>
      partitioner.map(origNode) foreach { case (instance, node) =>
        instanceWriters(instance).write(graphReaderFromDirectory.reverseParseNode(node))
      }
    }
    instanceWriters foreach { writer =>
      writer.flush()
      writer.close()
    }
  }