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

WALProcedureStore.rollWriter介绍

暂无

代码示例

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

private boolean tryRollWriter() {
 try {
  return rollWriter();
 } catch (IOException e) {
  LOG.warn("Unable to roll the log", e);
  return false;
 }
}

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

@VisibleForTesting
public boolean rollWriterForTesting() throws IOException {
 lock.lock();
 try {
  return rollWriter();
 } finally {
  lock.unlock();
 }
}

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

private boolean rollWriterWithRetries() {
 for (int i = 0; i < rollRetries && isRunning(); ++i) {
  if (i > 0) Threads.sleepWithoutInterrupt(waitBeforeRoll * i);
  try {
   if (rollWriter()) {
    return true;
   }
  } catch (IOException e) {
   LOG.warn("Unable to roll the log, attempt=" + (i + 1), e);
  }
 }
 LOG.error(HBaseMarkers.FATAL, "Unable to roll the log");
 return false;
}

代码示例来源：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

if (!rollWriter(flushLogId + 1)) {

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

@Test
public void testLogFileAleadExists() throws IOException {
 final boolean[] tested = {false};
 WALProcedureStore mStore = Mockito.spy(procStore);
 Answer<Boolean> ans = new Answer<Boolean>() {
  @Override
  public Boolean answer(InvocationOnMock invocationOnMock) throws Throwable {
   long logId = ((Long) invocationOnMock.getArgument(0)).longValue();
   switch ((int) logId) {
    case 2:
     // Create a file so that real rollWriter() runs into file exists condition
     Path logFilePath = mStore.getLogFilePath(logId);
     mStore.getFileSystem().create(logFilePath);
     break;
    case 3:
     // Success only when we retry with logId 3
     tested[0] = true;
    default:
     break;
   }
   return (Boolean) invocationOnMock.callRealMethod();
  }
 };
 // First time Store has one log file, next id will be 2
 Mockito.doAnswer(ans).when(mStore).rollWriter(2);
 // next time its 3
 Mockito.doAnswer(ans).when(mStore).rollWriter(3);
 mStore.recoverLease();
 assertTrue(tested[0]);
}

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

private boolean tryRollWriter() {
 try {
  return rollWriter();
 } catch (IOException e) {
  LOG.warn("Unable to roll the log", e);
  return false;
 }
}

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

private boolean tryRollWriter() {
 try {
  return rollWriter();
 } catch (IOException e) {
  LOG.warn("Unable to roll the log", e);
  return false;
 }
}

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

private boolean tryRollWriter() {
 try {
  return rollWriter();
 } catch (IOException e) {
  LOG.warn("Unable to roll the log", e);
  return false;
 }
}

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

@VisibleForTesting
protected boolean rollWriterForTesting() throws IOException {
 lock.lock();
 try {
  return rollWriter();
 } finally {
  lock.unlock();
 }
}

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

@VisibleForTesting
public boolean rollWriterForTesting() throws IOException {
 lock.lock();
 try {
  return rollWriter();
 } finally {
  lock.unlock();
 }
}

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

@VisibleForTesting
protected boolean rollWriterForTesting() throws IOException {
 lock.lock();
 try {
  return rollWriter();
 } finally {
  lock.unlock();
 }
}

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

private boolean rollWriterWithRetries() {
 for (int i = 0; i < rollRetries && isRunning(); ++i) {
  if (i > 0) Threads.sleepWithoutInterrupt(waitBeforeRoll * i);
  try {
   if (rollWriter()) {
    return true;
   }
  } catch (IOException e) {
   LOG.warn("Unable to roll the log, attempt=" + (i + 1), e);
  }
 }
 LOG.error(HBaseMarkers.FATAL, "Unable to roll the log");
 return false;
}

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

private boolean rollWriterWithRetries() {
 for (int i = 0; i < rollRetries && isRunning(); ++i) {
  if (i > 0) Threads.sleepWithoutInterrupt(waitBeforeRoll * i);
  try {
   if (rollWriter()) {
    return true;
   }
  } catch (IOException e) {
   LOG.warn("Unable to roll the log, attempt=" + (i + 1), e);
  }
 }
 LOG.error(HBaseMarkers.FATAL, "Unable to roll the log");
 return false;
}

代码示例来源：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: harbby/presto-connectors

private boolean rollWriterOrDie() {
 for (int i = 0; i < rollRetries; ++i) {
  if (i > 0) Threads.sleepWithoutInterrupt(waitBeforeRoll * i);
  try {
   if (rollWriter()) {
    return true;
   }
  } catch (IOException e) {
   LOG.warn("Unable to roll the log, attempt=" + (i + 1), e);
  }
 }
 LOG.fatal("Unable to roll the log");
 sendAbortProcessSignal();
 throw new RuntimeException("unable to roll the log");
}

代码示例来源：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: org.apache.hbase/hbase-procedure

@Test
public void testLogFileAleadExists() throws IOException {
 final boolean[] tested = {false};
 WALProcedureStore mStore = Mockito.spy(procStore);
 Answer<Boolean> ans = new Answer<Boolean>() {
  @Override
  public Boolean answer(InvocationOnMock invocationOnMock) throws Throwable {
   long logId = ((Long) invocationOnMock.getArgument(0)).longValue();
   switch ((int) logId) {
    case 2:
     // Create a file so that real rollWriter() runs into file exists condition
     Path logFilePath = mStore.getLogFilePath(logId);
     mStore.getFileSystem().create(logFilePath);
     break;
    case 3:
     // Success only when we retry with logId 3
     tested[0] = true;
    default:
     break;
   }
   return (Boolean) invocationOnMock.callRealMethod();
  }
 };
 // First time Store has one log file, next id will be 2
 Mockito.doAnswer(ans).when(mStore).rollWriter(2);
 // next time its 3
 Mockito.doAnswer(ans).when(mStore).rollWriter(3);
 mStore.recoverLease();
 assertTrue(tested[0]);
}

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

@Test
public void testLogFileAleadExists() throws IOException {
 final boolean[] tested = {false};
 WALProcedureStore mStore = Mockito.spy(procStore);
 Answer<Boolean> ans = new Answer<Boolean>() {
  @Override
  public Boolean answer(InvocationOnMock invocationOnMock) throws Throwable {
   long logId = ((Long) invocationOnMock.getArgument(0)).longValue();
   switch ((int) logId) {
    case 2:
     // Create a file so that real rollWriter() runs into file exists condition
     Path logFilePath = mStore.getLogFilePath(logId);
     mStore.getFileSystem().create(logFilePath);
     break;
    case 3:
     // Success only when we retry with logId 3
     tested[0] = true;
    default:
     break;
   }
   return (Boolean) invocationOnMock.callRealMethod();
  }
 };
 // First time Store has one log file, next id will be 2
 Mockito.doAnswer(ans).when(mStore).rollWriter(2);
 // next time its 3
 Mockito.doAnswer(ans).when(mStore).rollWriter(3);
 mStore.recoverLease();
 assertTrue(tested[0]);
}