Java 类org.apache.hadoop.hdfs.server.common.Storage.FormatConfirmable 实例源码

项目：hadoop-EAR 文件：FSEditLog.java

synchronized List<FormatConfirmable> getFormatConfirmables()
    throws IOException {
  if (state != State.BETWEEN_LOG_SEGMENTS) {
    throw new IOException("Bad state:" + state);
  }

  List<FormatConfirmable> ret = Lists.newArrayList();
  for (final JournalManager jm : journalSet.getJournalManagers()) {
    // The FJMs are confirmed separately since they are also
    // StorageDirectories
    if (!(jm instanceof FileJournalManager)) {
      ret.add(jm);
    }
  }
  return ret;
}

项目：hadoop 文件：FSEditLog.java

synchronized List<FormatConfirmable> getFormatConfirmables() {
  Preconditions.checkState(state == State.BETWEEN_LOG_SEGMENTS,
      "Bad state: %s", state);

  List<FormatConfirmable> ret = Lists.newArrayList();
  for (final JournalManager jm : journalSet.getJournalManagers()) {
    // The FJMs are confirmed separately since they are also
    // StorageDirectories
    if (!(jm instanceof FileJournalManager)) {
      ret.add(jm);
    }
  }
  return ret;
}

项目：aliyun-oss-hadoop-fs 文件：FSEditLog.java

synchronized List<FormatConfirmable> getFormatConfirmables() {
  Preconditions.checkState(state == State.BETWEEN_LOG_SEGMENTS,
      "Bad state: %s", state);

  List<FormatConfirmable> ret = Lists.newArrayList();
  for (final JournalManager jm : journalSet.getJournalManagers()) {
    // The FJMs are confirmed separately since they are also
    // StorageDirectories
    if (!(jm instanceof FileJournalManager)) {
      ret.add(jm);
    }
  }
  return ret;
}

项目：big-c 文件：FSEditLog.java

synchronized List<FormatConfirmable> getFormatConfirmables() {
  Preconditions.checkState(state == State.BETWEEN_LOG_SEGMENTS,
      "Bad state: %s", state);

  List<FormatConfirmable> ret = Lists.newArrayList();
  for (final JournalManager jm : journalSet.getJournalManagers()) {
    // The FJMs are confirmed separately since they are also
    // StorageDirectories
    if (!(jm instanceof FileJournalManager)) {
      ret.add(jm);
    }
  }
  return ret;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：FSEditLog.java

synchronized List<FormatConfirmable> getFormatConfirmables() {
  Preconditions.checkState(state == State.BETWEEN_LOG_SEGMENTS,
      "Bad state: %s", state);

  List<FormatConfirmable> ret = Lists.newArrayList();
  for (final JournalManager jm : journalSet.getJournalManagers()) {
    // The FJMs are confirmed separately since they are also
    // StorageDirectories
    if (!(jm instanceof FileJournalManager)) {
      ret.add(jm);
    }
  }
  return ret;
}

项目：hadoop-plus 文件：FSEditLog.java

synchronized List<FormatConfirmable> getFormatConfirmables() {
  Preconditions.checkState(state == State.BETWEEN_LOG_SEGMENTS,
      "Bad state: %s", state);

  List<FormatConfirmable> ret = Lists.newArrayList();
  for (final JournalManager jm : journalSet.getJournalManagers()) {
    // The FJMs are confirmed separately since they are also
    // StorageDirectories
    if (!(jm instanceof FileJournalManager)) {
      ret.add(jm);
    }
  }
  return ret;
}

项目：FlexMap 文件：FSEditLog.java

synchronized List<FormatConfirmable> getFormatConfirmables() {
  Preconditions.checkState(state == State.BETWEEN_LOG_SEGMENTS,
      "Bad state: %s", state);

  List<FormatConfirmable> ret = Lists.newArrayList();
  for (final JournalManager jm : journalSet.getJournalManagers()) {
    // The FJMs are confirmed separately since they are also
    // StorageDirectories
    if (!(jm instanceof FileJournalManager)) {
      ret.add(jm);
    }
  }
  return ret;
}

项目：hadoop-TCP 文件：FSEditLog.java

synchronized List<FormatConfirmable> getFormatConfirmables() {
  Preconditions.checkState(state == State.BETWEEN_LOG_SEGMENTS,
      "Bad state: %s", state);

  List<FormatConfirmable> ret = Lists.newArrayList();
  for (final JournalManager jm : journalSet.getJournalManagers()) {
    // The FJMs are confirmed separately since they are also
    // StorageDirectories
    if (!(jm instanceof FileJournalManager)) {
      ret.add(jm);
    }
  }
  return ret;
}

项目：hardfs 文件：FSEditLog.java

synchronized List<FormatConfirmable> getFormatConfirmables() {
  Preconditions.checkState(state == State.BETWEEN_LOG_SEGMENTS,
      "Bad state: %s", state);

  List<FormatConfirmable> ret = Lists.newArrayList();
  for (final JournalManager jm : journalSet.getJournalManagers()) {
    // The FJMs are confirmed separately since they are also
    // StorageDirectories
    if (!(jm instanceof FileJournalManager)) {
      ret.add(jm);
    }
  }
  return ret;
}

项目：hadoop-on-lustre2 文件：FSEditLog.java

synchronized List<FormatConfirmable> getFormatConfirmables() {
  Preconditions.checkState(state == State.BETWEEN_LOG_SEGMENTS,
      "Bad state: %s", state);

  List<FormatConfirmable> ret = Lists.newArrayList();
  for (final JournalManager jm : journalSet.getJournalManagers()) {
    // The FJMs are confirmed separately since they are also
    // StorageDirectories
    if (!(jm instanceof FileJournalManager)) {
      ret.add(jm);
    }
  }
  return ret;
}

项目：hadoop 文件：FSImage.java

/**
 * Check whether the storage directories and non-file journals exist.
 * If running in interactive mode, will prompt the user for each
 * directory to allow them to format anyway. Otherwise, returns
 * false, unless 'force' is specified.
 * 
 * @param force if true, format regardless of whether dirs exist
 * @param interactive prompt the user when a dir exists
 * @return true if formatting should proceed
 * @throws IOException if some storage cannot be accessed
 */
boolean confirmFormat(boolean force, boolean interactive) throws IOException {
  List<FormatConfirmable> confirms = Lists.newArrayList();
  for (StorageDirectory sd : storage.dirIterable(null)) {
    confirms.add(sd);
  }

  confirms.addAll(editLog.getFormatConfirmables());
  return Storage.confirmFormat(confirms, force, interactive);
}

项目：aliyun-oss-hadoop-fs 文件：FSImage.java

/**
 * Check whether the storage directories and non-file journals exist.
 * If running in interactive mode, will prompt the user for each
 * directory to allow them to format anyway. Otherwise, returns
 * false, unless 'force' is specified.
 * 
 * @param force if true, format regardless of whether dirs exist
 * @param interactive prompt the user when a dir exists
 * @return true if formatting should proceed
 * @throws IOException if some storage cannot be accessed
 */
boolean confirmFormat(boolean force, boolean interactive) throws IOException {
  List<FormatConfirmable> confirms = Lists.newArrayList();
  for (StorageDirectory sd : storage.dirIterable(null)) {
    confirms.add(sd);
  }

  confirms.addAll(editLog.getFormatConfirmables());
  return Storage.confirmFormat(confirms, force, interactive);
}

项目：big-c 文件：FSImage.java

/**
 * Check whether the storage directories and non-file journals exist.
 * If running in interactive mode, will prompt the user for each
 * directory to allow them to format anyway. Otherwise, returns
 * false, unless 'force' is specified.
 * 
 * @param force if true, format regardless of whether dirs exist
 * @param interactive prompt the user when a dir exists
 * @return true if formatting should proceed
 * @throws IOException if some storage cannot be accessed
 */
boolean confirmFormat(boolean force, boolean interactive) throws IOException {
  List<FormatConfirmable> confirms = Lists.newArrayList();
  for (StorageDirectory sd : storage.dirIterable(null)) {
    confirms.add(sd);
  }

  confirms.addAll(editLog.getFormatConfirmables());
  return Storage.confirmFormat(confirms, force, interactive);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：FSImage.java

/**
 * Check whether the storage directories and non-file journals exist.
 * If running in interactive mode, will prompt the user for each
 * directory to allow them to format anyway. Otherwise, returns
 * false, unless 'force' is specified.
 * 
 * @param force if true, format regardless of whether dirs exist
 * @param interactive prompt the user when a dir exists
 * @return true if formatting should proceed
 * @throws IOException if some storage cannot be accessed
 */
boolean confirmFormat(boolean force, boolean interactive) throws IOException {
  List<FormatConfirmable> confirms = Lists.newArrayList();
  for (StorageDirectory sd : storage.dirIterable(null)) {
    confirms.add(sd);
  }

  confirms.addAll(editLog.getFormatConfirmables());
  return Storage.confirmFormat(confirms, force, interactive);
}

项目：hadoop-EAR 文件：FSImage.java

/**
 * Check whether the storage directories and non-file journals exist.
 * If running in interactive mode, will prompt the user for each
 * directory to allow them to format anyway. Otherwise, returns
 * false, unless 'force' is specified.
 * 
 * @param interactive prompt the user when a dir exists
 * @return true if formatting should proceed
 * @throws IOException if some storage cannot be accessed
 */
boolean confirmFormat(boolean force, boolean interactive) throws IOException {
  List<FormatConfirmable> confirms = Lists.newArrayList();
  for (StorageDirectory sd : storage.dirIterable(null)) {
    confirms.add(sd);
  }   
  confirms.addAll(editLog.getFormatConfirmables());
  return Storage.confirmFormat(confirms, force, interactive);
}

项目：hadoop-plus 文件：FSImage.java

/**
 * Check whether the storage directories and non-file journals exist.
 * If running in interactive mode, will prompt the user for each
 * directory to allow them to format anyway. Otherwise, returns
 * false, unless 'force' is specified.
 * 
 * @param force format regardless of whether dirs exist
 * @param interactive prompt the user when a dir exists
 * @return true if formatting should proceed
 * @throws IOException if some storage cannot be accessed
 */
boolean confirmFormat(boolean force, boolean interactive) throws IOException {
  List<FormatConfirmable> confirms = Lists.newArrayList();
  for (StorageDirectory sd : storage.dirIterable(null)) {
    confirms.add(sd);
  }

  confirms.addAll(editLog.getFormatConfirmables());
  return Storage.confirmFormat(confirms, force, interactive);
}

项目：FlexMap 文件：FSImage.java

/**
 * Check whether the storage directories and non-file journals exist.
 * If running in interactive mode, will prompt the user for each
 * directory to allow them to format anyway. Otherwise, returns
 * false, unless 'force' is specified.
 * 
 * @param force if true, format regardless of whether dirs exist
 * @param interactive prompt the user when a dir exists
 * @return true if formatting should proceed
 * @throws IOException if some storage cannot be accessed
 */
boolean confirmFormat(boolean force, boolean interactive) throws IOException {
  List<FormatConfirmable> confirms = Lists.newArrayList();
  for (StorageDirectory sd : storage.dirIterable(null)) {
    confirms.add(sd);
  }

  confirms.addAll(editLog.getFormatConfirmables());
  return Storage.confirmFormat(confirms, force, interactive);
}

项目：hadoop-TCP 文件：FSImage.java

/**
 * Check whether the storage directories and non-file journals exist.
 * If running in interactive mode, will prompt the user for each
 * directory to allow them to format anyway. Otherwise, returns
 * false, unless 'force' is specified.
 * 
 * @param force format regardless of whether dirs exist
 * @param interactive prompt the user when a dir exists
 * @return true if formatting should proceed
 * @throws IOException if some storage cannot be accessed
 */
boolean confirmFormat(boolean force, boolean interactive) throws IOException {
  List<FormatConfirmable> confirms = Lists.newArrayList();
  for (StorageDirectory sd : storage.dirIterable(null)) {
    confirms.add(sd);
  }

  confirms.addAll(editLog.getFormatConfirmables());
  return Storage.confirmFormat(confirms, force, interactive);
}

项目：hardfs 文件：FSImage.java

/**
 * Check whether the storage directories and non-file journals exist.
 * If running in interactive mode, will prompt the user for each
 * directory to allow them to format anyway. Otherwise, returns
 * false, unless 'force' is specified.
 * 
 * @param force format regardless of whether dirs exist
 * @param interactive prompt the user when a dir exists
 * @return true if formatting should proceed
 * @throws IOException if some storage cannot be accessed
 */
boolean confirmFormat(boolean force, boolean interactive) throws IOException {
  List<FormatConfirmable> confirms = Lists.newArrayList();
  for (StorageDirectory sd : storage.dirIterable(null)) {
    confirms.add(sd);
  }

  confirms.addAll(editLog.getFormatConfirmables());
  return Storage.confirmFormat(confirms, force, interactive);
}

项目：hadoop-on-lustre2 文件：FSImage.java

/**
 * Check whether the storage directories and non-file journals exist.
 * If running in interactive mode, will prompt the user for each
 * directory to allow them to format anyway. Otherwise, returns
 * false, unless 'force' is specified.
 * 
 * @param force format regardless of whether dirs exist
 * @param interactive prompt the user when a dir exists
 * @return true if formatting should proceed
 * @throws IOException if some storage cannot be accessed
 */
boolean confirmFormat(boolean force, boolean interactive) throws IOException {
  List<FormatConfirmable> confirms = Lists.newArrayList();
  for (StorageDirectory sd : storage.dirIterable(null)) {
    confirms.add(sd);
  }

  confirms.addAll(editLog.getFormatConfirmables());
  return Storage.confirmFormat(confirms, force, interactive);
}