/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/ |
H A D | JNStorage.java | 144 void purgeDataOlderThan(long minTxIdToKeep) throws IOException { in purgeDataOlderThan() argument 146 CURRENT_DIR_PURGE_REGEXES, minTxIdToKeep); in purgeDataOlderThan() local 147 purgeMatching(getPaxosDir(), PAXOS_DIR_PURGE_REGEXES, minTxIdToKeep); in purgeDataOlderThan() local 158 long minTxIdToKeep) throws IOException { in purgeMatching() argument 169 if (txid < minTxIdToKeep) { in purgeMatching()
|
H A D | JournalNodeRpcServer.java | 173 public void purgeLogsOlderThan(RequestInfo reqInfo, long minTxIdToKeep) in purgeLogsOlderThan() argument 176 .purgeLogsOlderThan(reqInfo, minTxIdToKeep); in purgeLogsOlderThan()
|
H A D | Journal.java | 615 long minTxIdToKeep) throws IOException { in purgeLogsOlderThan() argument 619 storage.purgeDataOlderThan(minTxIdToKeep); in purgeLogsOlderThan()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ |
H A D | LogsPurgeable.java | 36 public void purgeLogsOlderThan(long minTxIdToKeep) throws IOException; in purgeLogsOlderThan() argument
|
H A D | FileJournalManager.java | 162 public void purgeLogsOlderThan(long minTxIdToKeep) in purgeLogsOlderThan() argument 164 LOG.info("Purging logs older than " + minTxIdToKeep); in purgeLogsOlderThan() 168 if (log.getFirstTxId() < minTxIdToKeep && in purgeLogsOlderThan() 169 log.getLastTxId() < minTxIdToKeep) { in purgeLogsOlderThan()
|
H A D | BackupJournalManager.java | 77 public void purgeLogsOlderThan(long minTxIdToKeep) in purgeLogsOlderThan() argument
|
H A D | JournalSet.java | 610 public void purgeLogsOlderThan(final long minTxIdToKeep) throws IOException { in purgeLogsOlderThan() argument 614 jas.getManager().purgeLogsOlderThan(minTxIdToKeep); in purgeLogsOlderThan() 616 }, "purgeLogsOlderThan " + minTxIdToKeep); in purgeLogsOlderThan()
|
H A D | FSEditLog.java | 1306 public synchronized void purgeLogsOlderThan(final long minTxIdToKeep) { in purgeLogsOlderThan() argument 1314 minTxIdToKeep <= curSegmentTxId : in purgeLogsOlderThan() local 1315 "cannot purge logs older than txid " + minTxIdToKeep + in purgeLogsOlderThan() 1317 if (minTxIdToKeep == 0) { in purgeLogsOlderThan() 1324 journalSet.purgeLogsOlderThan(minTxIdToKeep); in purgeLogsOlderThan()
|
H A D | SecondaryNameNode.java | 870 public void purgeLogsOlderThan(long minTxIdToKeep) throws IOException { in purgeLogsOlderThan() argument 877 if (f.getLastTxId() < minTxIdToKeep) { in purgeLogsOlderThan()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/ |
H A D | AsyncLogger.java | 87 public ListenableFuture<Void> purgeLogsOlderThan(long minTxIdToKeep); in purgeLogsOlderThan() argument
|
H A D | QuorumJournalManager.java | 424 public void purgeLogsOlderThan(long minTxIdToKeep) throws IOException { in purgeLogsOlderThan() argument 427 LOG.info("Purging remote journals older than txid " + minTxIdToKeep); in purgeLogsOlderThan() 428 loggers.purgeLogsOlderThan(minTxIdToKeep); in purgeLogsOlderThan()
|
H A D | AsyncLoggerSet.java | 106 void purgeLogsOlderThan(long minTxIdToKeep) { in purgeLogsOlderThan() argument 108 logger.purgeLogsOlderThan(minTxIdToKeep); in purgeLogsOlderThan()
|
H A D | IPCLoggerChannel.java | 540 public ListenableFuture<Void> purgeLogsOlderThan(final long minTxIdToKeep) { 544 getProxy().purgeLogsOlderThan(createReqInfo(), minTxIdToKeep);
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/protocol/ |
H A D | QJournalProtocol.java | 123 public void purgeLogsOlderThan(RequestInfo requestInfo, long minTxIdToKeep) in purgeLogsOlderThan() argument
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/protocolPB/ |
H A D | QJournalProtocolTranslatorPB.java | 227 public void purgeLogsOlderThan(RequestInfo reqInfo, long minTxIdToKeep) in purgeLogsOlderThan() argument 231 .setMinTxIdToKeep(minTxIdToKeep) in purgeLogsOlderThan()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ |
H A D | TestGenericJournalConf.java | 186 public void purgeLogsOlderThan(long minTxIdToKeep) in purgeLogsOlderThan() argument
|
/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 | 676 public void purgeLogsOlderThan(long minTxIdToKeep) in purgeLogsOlderThan() argument 681 if (l.getLastTxId() < minTxIdToKeep) { in purgeLogsOlderThan()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/proto/ |
H A D | QJournalProtocol.proto | 120 required uint64 minTxIdToKeep = 2;
|