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

WALProcedureStore.getLogFiles介绍

暂无

代码示例

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

private boolean rollWriter() throws IOException {
 if (!isRunning()) {
  return false;
 }
 // Create new state-log
 if (!rollWriter(flushLogId + 1)) {
  LOG.warn("someone else has already created log {}", flushLogId);
  return false;
 }
 // We have the lease on the log,
 // but we should check if someone else has created new files
 if (getMaxLogId(getLogFiles()) > flushLogId) {
  LOG.warn("Someone else created new logs. Expected maxLogId < {}", flushLogId);
  logs.getLast().removeFile(this.walArchiveDir);
  return false;
 }
 // We have the lease on the log
 return true;
}

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

afterFirstAttempt = true;
FileStatus[] oldLogs = getLogFiles();
oldLogs = getLogFiles();
if (getMaxLogId(oldLogs) > flushLogId) {
 LOG.debug("Someone else created new logs. Expected maxLogId < {}", flushLogId);

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

private boolean rollWriter() throws IOException {
 if (!isRunning()) return false;
 // Create new state-log
 if (!rollWriter(flushLogId + 1)) {
  LOG.warn("someone else has already created log " + flushLogId);
  return false;
 }
 // We have the lease on the log,
 // but we should check if someone else has created new files
 if (getMaxLogId(getLogFiles()) > flushLogId) {
  LOG.warn("Someone else created new logs. Expected maxLogId < " + flushLogId);
  logs.getLast().removeFile(this.walArchiveDir);
  return false;
 }
 // We have the lease on the log
 return true;
}

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

private boolean rollWriter() throws IOException {
 if (!isRunning()) {
  return false;
 }
 // Create new state-log
 if (!rollWriter(flushLogId + 1)) {
  LOG.warn("someone else has already created log {}", flushLogId);
  return false;
 }
 // We have the lease on the log,
 // but we should check if someone else has created new files
 if (getMaxLogId(getLogFiles()) > flushLogId) {
  LOG.warn("Someone else created new logs. Expected maxLogId < {}", flushLogId);
  logs.getLast().removeFile(this.walArchiveDir);
  return false;
 }
 // We have the lease on the log
 return true;
}

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

afterFirstAttempt = true;
FileStatus[] oldLogs = getLogFiles();
oldLogs = getLogFiles();
if (getMaxLogId(oldLogs) > flushLogId) {
 if (LOG.isDebugEnabled()) {

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

afterFirstAttempt = true;
FileStatus[] oldLogs = getLogFiles();
oldLogs = getLogFiles();
if (getMaxLogId(oldLogs) > flushLogId) {
 LOG.debug("Someone else created new logs. Expected maxLogId < {}", flushLogId);

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

private boolean rollWriter() throws IOException {
 // Create new state-log
 if (!rollWriter(flushLogId + 1)) {
  LOG.warn("someone else has already created log " + flushLogId);
  return false;
 }
 // We have the lease on the log,
 // but we should check if someone else has created new files
 if (getMaxLogId(getLogFiles()) > flushLogId) {
  LOG.warn("Someone else created new logs. Expected maxLogId < " + flushLogId);
  logs.getLast().removeFile();
  return false;
 }
 // We have the lease on the log
 return true;
}

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

try {
 LOG.info("Starting WAL Procedure Store lease recovery");
 FileStatus[] oldLogs = getLogFiles();
 while (isRunning()) {
  oldLogs = getLogFiles();
  if (getMaxLogId(oldLogs) > flushLogId) {
   if (LOG.isDebugEnabled()) {