本文整理了Java中org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore.removeLogFile()方法的一些代码示例，展示了WALProcedureStore.removeLogFile()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WALProcedureStore.removeLogFile()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
类名称：WALProcedureStore
方法名：removeLogFile

WALProcedureStore.removeLogFile介绍

暂无

代码示例

代码示例来源：origin: apache/hbase

private void removeInactiveLogs() throws IOException {
 // We keep track of which procedures are holding the oldest WAL in 'holdingCleanupTracker'.
 // once there is nothing olding the oldest WAL we can remove it.
 while (logs.size() > 1 && holdingCleanupTracker.isEmpty()) {
  LOG.info("Remove the oldest log {}", logs.getFirst());
  removeLogFile(logs.getFirst(), walArchiveDir);
  buildHoldingCleanupTracker();
 }
 // TODO: In case we are holding up a lot of logs for long time we should
 // rewrite old procedures (in theory parent procs) to the new WAL.
}

代码示例来源：origin: apache/hbase

/**
 * Remove all logs with logId <= {@code lastLogId}.
 */
private void removeAllLogs(long lastLogId, String why) {
 if (logs.size() <= 1) {
  return;
 }
 LOG.info("Remove all state logs with ID less than {}, since {}", lastLogId, why);
 boolean removed = false;
 while (logs.size() > 1) {
  ProcedureWALFile log = logs.getFirst();
  if (lastLogId < log.getLogId()) {
   break;
  }
  removeLogFile(log, walArchiveDir);
  removed = true;
 }
 if (removed) {
  buildHoldingCleanupTracker();
 }
}

代码示例来源：origin: org.apache.hbase/hbase-procedure

private void removeInactiveLogs() throws IOException {
 // We keep track of which procedures are holding the oldest WAL in 'holdingCleanupTracker'.
 // once there is nothing olding the oldest WAL we can remove it.
 while (logs.size() > 1 && holdingCleanupTracker.isEmpty()) {
  LOG.info("Remove the oldest log {}", logs.getFirst());
  removeLogFile(logs.getFirst(), walArchiveDir);
  buildHoldingCleanupTracker();
 }
 // TODO: In case we are holding up a lot of logs for long time we should
 // rewrite old procedures (in theory parent procs) to the new WAL.
}

代码示例来源：origin: com.aliyun.hbase/alihbase-procedure

private void removeInactiveLogs() throws IOException {
 // We keep track of which procedures are holding the oldest WAL in 'holdingCleanupTracker'.
 // once there is nothing olding the oldest WAL we can remove it.
 while (logs.size() > 1 && holdingCleanupTracker.isEmpty()) {
  removeLogFile(logs.getFirst(), walArchiveDir);
  buildHoldingCleanupTracker();
 }
 // TODO: In case we are holding up a lot of logs for long time we should
 // rewrite old procedures (in theory parent procs) to the new WAL.
}

代码示例来源：origin: harbby/presto-connectors

private void removeAllLogs(long lastLogId) {
 if (logs.size() <= 1) return;
 if (LOG.isDebugEnabled()) {
  LOG.debug("Remove all state logs with ID less than " + lastLogId);
 }
 while (logs.size() > 1) {
  ProcedureWALFile log = logs.getFirst();
  if (lastLogId < log.getLogId()) {
   break;
  }
  removeLogFile(log);
 }
}

代码示例来源：origin: com.aliyun.hbase/alihbase-procedure

/**
 * Remove all logs with logId <= {@code lastLogId}.
 */
private void removeAllLogs(long lastLogId) {
 if (logs.size() <= 1) return;
 if (LOG.isTraceEnabled()) {
  LOG.trace("Remove all state logs with ID less than " + lastLogId);
 }
 boolean removed = false;
 while (logs.size() > 1) {
  ProcedureWALFile log = logs.getFirst();
  if (lastLogId < log.getLogId()) {
   break;
  }
  removeLogFile(log, walArchiveDir);
  removed = true;
 }
 if (removed) {
  buildHoldingCleanupTracker();
 }
}

代码示例来源：origin: org.apache.hbase/hbase-procedure

/**
 * Remove all logs with logId <= {@code lastLogId}.
 */
private void removeAllLogs(long lastLogId, String why) {
 if (logs.size() <= 1) {
  return;
 }
 LOG.info("Remove all state logs with ID less than {}, since {}", lastLogId, why);
 boolean removed = false;
 while (logs.size() > 1) {
  ProcedureWALFile log = logs.getFirst();
  if (lastLogId < log.getLogId()) {
   break;
  }
  removeLogFile(log, walArchiveDir);
  removed = true;
 }
 if (removed) {
  buildHoldingCleanupTracker();
 }
}

代码示例来源：origin: harbby/presto-connectors

private void removeInactiveLogs() {
 // Verify if the ProcId of the first oldest is still active. if not remove the file.
 while (logs.size() > 1) {
  ProcedureWALFile log = logs.getFirst();
  if (storeTracker.isTracking(log.getMinProcId(), log.getMaxProcId())) {
   break;
  }
  removeLogFile(log);
 }
}