Searched refs:finalizedLedgerZNode (Results 1 – 2 of 2) sorted by relevance
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/contrib/bkjournal/src/test/java/org/apache/hadoop/contrib/bkjournal/ |
| H A D | TestBookKeeperJournalManager.java | 119 String zkpath = bkjm.finalizedLedgerZNode(1, 100); in testSimpleWrite()
167 zkc.exists(bkjm.finalizedLedgerZNode(start, txid-1), false)); in testNumberOfTransactionsWithGaps()
169 zkc.delete(bkjm.finalizedLedgerZNode(DEFAULT_SEGMENT_SIZE+1, in testNumberOfTransactionsWithGaps()
207 zkc.exists(bkjm.finalizedLedgerZNode(start, (txid-1)), false)); in testNumberOfTransactionsWithInprogressAtEnd()
369 assertNull(zkc.exists(bkjm.finalizedLedgerZNode(1, 100), false)); in testSimpleRecovery()
374 assertNotNull(zkc.exists(bkjm.finalizedLedgerZNode(1, 100), false)); in testSimpleRecovery()
691 String finalizedZNode = bkjm.finalizedLedgerZNode(1, 100); in testRefinalizeAlreadyFinalizedInprogress()
979 String zkpath1 = bkjm.finalizedLedgerZNode(startTxid, endTxid); in startAndFinalizeLogSegment()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/contrib/bkjournal/src/main/java/org/apache/hadoop/contrib/bkjournal/ |
| H A D | BookKeeperJournalManager.java | 516 String finalisedPath = finalizedLedgerZNode(firstTxId, lastTxId); in finalizeLogSegment()
857 String finalizedLedgerZNode(long startTxId, long endTxId) { in finalizedLedgerZNode() method in BookKeeperJournalManager
|