(Collection<String> fragPaths, Collection<String> refFastas, boolean loadPairedKmers, int numThreads)
| 1539 | } |
| 1540 | |
| 1541 | public void populateGraphFromFragments(Collection<String> fragPaths, Collection<String> refFastas, boolean loadPairedKmers, int numThreads) throws InterruptedException { |
| 1542 | ExecutorService service = Executors.newFixedThreadPool(numThreads); |
| 1543 | |
| 1544 | int threadId = 0; |
| 1545 | |
| 1546 | for (String path : fragPaths) { |
| 1547 | service.submit(new FragmentsToGraphWorker(++threadId, path, loadPairedKmers)); |
| 1548 | } |
| 1549 | |
| 1550 | service.shutdown(); |
| 1551 | service.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS); |
| 1552 | |
| 1553 | if (!refFastas.isEmpty()) { |
| 1554 | System.out.println("Augmenting graph with reference transcripts..."); |
| 1555 | |
| 1556 | service = Executors.newFixedThreadPool(numThreads); |
| 1557 | |
| 1558 | for (String path : refFastas) { |
| 1559 | service.submit(new PairedKmersToGraphWorker(++threadId, path, true)); |
| 1560 | } |
| 1561 | |
| 1562 | service.shutdown(); |
| 1563 | service.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS); |
| 1564 | } |
| 1565 | |
| 1566 | dbgFPR = graph.getDbgbfFPR(); |
| 1567 | |
| 1568 | System.out.println("DBG Bloom filter FPR: " + convertToRoundedPercent(dbgFPR) + " %"); |
| 1569 | System.out.println("Reads paired k-mers Bloom filter FPR: " + convertToRoundedPercent(graph.getRpkbf().getFPR()) + " %"); |
| 1570 | System.out.println("Fragments paired k-mers Bloom filter FPR: " + convertToRoundedPercent(graph.getFpkbf().getFPR()) + " %"); |
| 1571 | // covFPR = graph.getCbfFPR(); |
| 1572 | } |
| 1573 | |
| 1574 | public static class ReadPair { |
| 1575 | ArrayList<Kmer> leftKmers; |
no test coverage detected