1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.io.HLogLink

Java 类org.apache.hadoop.hbase.io.HLogLink 实例源码

项目：LCIndex-HBase-0.94.16    文件：ExportSnapshot.java    
private FileStatus getFileStatus(final FileSystem fs, final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      HFileLink link = new HFileLink(inputRoot, inputArchive, path);
      return link.getFileStatus(fs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).getFileStatus(fs);
    }
    return fs.getFileStatus(path);
  } catch (IOException e) {
    LOG.warn("Unable to get the status for file=" + path);
    return null;
  }
}
项目：HIndex    文件：ExportSnapshot.java    
/**
 * Try to open the "source" file.
 * Throws an IOException if the communication with the inputFs fail or
 * if the file is not found.
 */
private FSDataInputStream openSourceFile(Context context, final Path path) throws IOException {
  try {
    if (HFileLink.isHFileLink(path) || StoreFileInfo.isReference(path)) {
      return new HFileLink(inputRoot, inputArchive, path).open(inputFs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).open(inputFs);
    }
    return inputFs.open(path);
  } catch (IOException e) {
    context.getCounter(Counter.MISSING_FILES).increment(1);
    LOG.error("Unable to open source file=" + path, e);
    throw e;
  }
}
项目：IRIndex    文件：ExportSnapshot.java    
private FileStatus getFileStatus(final FileSystem fs, final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      HFileLink link = new HFileLink(inputRoot, inputArchive, path);
      return link.getFileStatus(fs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).getFileStatus(fs);
    }
    return fs.getFileStatus(path);
  } catch (IOException e) {
    LOG.warn("Unable to get the status for file=" + path);
    return null;
  }
}
项目：c5    文件：ExportSnapshot.java    
private FileStatus getFileStatus(final FileSystem fs, final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFileInfo.isReference(path)) {
      HFileLink link = new HFileLink(inputRoot, inputArchive, path);
      return link.getFileStatus(fs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).getFileStatus(fs);
    }
    return fs.getFileStatus(path);
  } catch (IOException e) {
    LOG.warn("Unable to get the status for file=" + path);
    return null;
  }
}
项目：HBase-Research    文件：ExportSnapshot.java    
private FileStatus getFileStatus(final FileSystem fs, final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      HFileLink link = new HFileLink(inputRoot, inputArchive, path);
      return link.getFileStatus(fs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).getFileStatus(fs);
    }
    return fs.getFileStatus(path);
  } catch (IOException e) {
    LOG.warn("Unable to get the status for file=" + path);
    return null;
  }
}
项目：hbase-0.94.8-qod    文件：ExportSnapshot.java    
private FileStatus getFileStatus(final FileSystem fs, final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      HFileLink link = new HFileLink(inputRoot, inputArchive, path);
      return link.getFileStatus(fs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).getFileStatus(fs);
    }
    return fs.getFileStatus(path);
  } catch (IOException e) {
    LOG.warn("Unable to get the status for file=" + path);
    return null;
  }
}
项目：hbase-0.94.8-qod    文件：ExportSnapshot.java    
private FileStatus getFileStatus(final FileSystem fs, final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      HFileLink link = new HFileLink(inputRoot, inputArchive, path);
      return link.getFileStatus(fs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).getFileStatus(fs);
    }
    return fs.getFileStatus(path);
  } catch (IOException e) {
    LOG.warn("Unable to get the status for file=" + path);
    return null;
  }
}
项目：hindex    文件：ExportSnapshot.java    
private FileStatus getFileStatus(final FileSystem fs, final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      HFileLink link = new HFileLink(inputRoot, inputArchive, path);
      return link.getFileStatus(fs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).getFileStatus(fs);
    }
    return fs.getFileStatus(path);
  } catch (IOException e) {
    LOG.warn("Unable to get the status for file=" + path);
    return null;
  }
}
项目：LCIndex-HBase-0.94.16    文件：ExportSnapshot.java    
private FSDataInputStream openSourceFile(final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      return new HFileLink(inputRoot, inputArchive, path).open(inputFs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).open(inputFs);
    }
    return inputFs.open(path);
  } catch (IOException e) {
    LOG.error("Unable to open source file=" + path, e);
    return null;
  }
}
项目：LCIndex-HBase-0.94.16    文件：SnapshotInfo.java    
/**
 * Add the specified log file to the stats
 * @param server server name
 * @param logfile log file name
 * @return the log information
 */
FileInfo addLogFile(final String server, final String logfile) throws IOException {
  HLogLink logLink = new HLogLink(conf, server, logfile);
  long size = -1;
  try {
    size = logLink.getFileStatus(fs).getLen();
    logSize += size;
    logsCount++;
  } catch (FileNotFoundException e) {
    logsMissing++;
  }
  return new FileInfo(false, size);
}
项目：HIndex    文件：SnapshotInfo.java    
/**
 * Add the specified log file to the stats
 * @param server server name
 * @param logfile log file name
 * @return the log information
 */
FileInfo addLogFile(final String server, final String logfile) throws IOException {
  HLogLink logLink = new HLogLink(conf, server, logfile);
  long size = -1;
  try {
    size = logLink.getFileStatus(fs).getLen();
    logSize += size;
    logsCount++;
  } catch (FileNotFoundException e) {
    logsMissing++;
  }
  return new FileInfo(false, size);
}
项目：IRIndex    文件：ExportSnapshot.java    
private FSDataInputStream openSourceFile(final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      return new HFileLink(inputRoot, inputArchive, path).open(inputFs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).open(inputFs);
    }
    return inputFs.open(path);
  } catch (IOException e) {
    LOG.error("Unable to open source file=" + path, e);
    return null;
  }
}
项目：IRIndex    文件：SnapshotInfo.java    
/**
 * Add the specified log file to the stats
 * @param server server name
 * @param logfile log file name
 * @return the log information
 */
FileInfo addLogFile(final String server, final String logfile) throws IOException {
  HLogLink logLink = new HLogLink(conf, server, logfile);
  long size = -1;
  try {
    size = logLink.getFileStatus(fs).getLen();
    logSize += size;
    logsCount++;
  } catch (FileNotFoundException e) {
    logsMissing++;
  }
  return new FileInfo(false, size);
}
项目：PyroDB    文件：SnapshotInfo.java    
/**
 * Add the specified log file to the stats
 * @param server server name
 * @param logfile log file name
 * @return the log information
 */
FileInfo addLogFile(final String server, final String logfile) throws IOException {
  HLogLink logLink = new HLogLink(conf, server, logfile);
  long size = -1;
  try {
    size = logLink.getFileStatus(fs).getLen();
    logSize.addAndGet(size);
    logsCount.incrementAndGet();
  } catch (FileNotFoundException e) {
    logsMissing.incrementAndGet();
  }
  return new FileInfo(false, size);
}
项目：c5    文件：ExportSnapshot.java    
private FSDataInputStream openSourceFile(final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFileInfo.isReference(path)) {
      return new HFileLink(inputRoot, inputArchive, path).open(inputFs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).open(inputFs);
    }
    return inputFs.open(path);
  } catch (IOException e) {
    LOG.error("Unable to open source file=" + path, e);
    return null;
  }
}
项目：c5    文件：SnapshotInfo.java    
/**
 * Add the specified log file to the stats
 * @param server server name
 * @param logfile log file name
 * @return the log information
 */
FileInfo addLogFile(final String server, final String logfile) throws IOException {
  HLogLink logLink = new HLogLink(conf, server, logfile);
  long size = -1;
  try {
    size = logLink.getFileStatus(fs).getLen();
    logSize += size;
    logsCount++;
  } catch (FileNotFoundException e) {
    logsMissing++;
  }
  return new FileInfo(false, size);
}
项目：HBase-Research    文件：ExportSnapshot.java    
private FSDataInputStream openSourceFile(final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      return new HFileLink(inputRoot, inputArchive, path).open(inputFs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).open(inputFs);
    }
    return inputFs.open(path);
  } catch (IOException e) {
    LOG.error("Unable to open source file=" + path, e);
    return null;
  }
}
项目：HBase-Research    文件：SnapshotInfo.java    
/**
 * Add the specified log file to the stats
 * @param server server name
 * @param logfile log file name
 * @return the log information
 */
FileInfo addLogFile(final String server, final String logfile) throws IOException {
  HLogLink logLink = new HLogLink(conf, server, logfile);
  long size = -1;
  try {
    size = logLink.getFileStatus(fs).getLen();
    logSize += size;
    logsCount++;
  } catch (FileNotFoundException e) {
    logsMissing++;
  }
  return new FileInfo(false, size);
}
项目：hbase-0.94.8-qod    文件：ExportSnapshot.java    
private FSDataInputStream openSourceFile(final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      return new HFileLink(inputRoot, inputArchive, path).open(inputFs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).open(inputFs);
    }
    return inputFs.open(path);
  } catch (IOException e) {
    LOG.error("Unable to open source file=" + path, e);
    return null;
  }
}
项目：hbase-0.94.8-qod    文件：SnapshotInfo.java    
/**
 * Add the specified log file to the stats
 * @param server server name
 * @param logfile log file name
 * @return the log information
 */
FileInfo addLogFile(final String server, final String logfile) throws IOException {
  HLogLink logLink = new HLogLink(conf, server, logfile);
  long size = -1;
  try {
    size = logLink.getFileStatus(fs).getLen();
    logSize += size;
    logsCount++;
  } catch (FileNotFoundException e) {
    logsMissing++;
  }
  return new FileInfo(false, size);
}
项目：hbase-0.94.8-qod    文件：ExportSnapshot.java    
private FSDataInputStream openSourceFile(final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      return new HFileLink(inputRoot, inputArchive, path).open(inputFs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).open(inputFs);
    }
    return inputFs.open(path);
  } catch (IOException e) {
    LOG.error("Unable to open source file=" + path, e);
    return null;
  }
}
项目：hbase-0.94.8-qod    文件：SnapshotInfo.java    
/**
 * Add the specified log file to the stats
 * @param server server name
 * @param logfile log file name
 * @return the log information
 */
FileInfo addLogFile(final String server, final String logfile) throws IOException {
  HLogLink logLink = new HLogLink(conf, server, logfile);
  long size = -1;
  try {
    size = logLink.getFileStatus(fs).getLen();
    logSize += size;
    logsCount++;
  } catch (FileNotFoundException e) {
    logsMissing++;
  }
  return new FileInfo(false, size);
}
项目：hindex    文件：ExportSnapshot.java    
private FSDataInputStream openSourceFile(final Path path) {
  try {
    if (HFileLink.isHFileLink(path) || StoreFile.isReference(path)) {
      return new HFileLink(inputRoot, inputArchive, path).open(inputFs);
    } else if (isHLogLinkPath(path)) {
      String serverName = path.getParent().getName();
      String logName = path.getName();
      return new HLogLink(inputRoot, serverName, logName).open(inputFs);
    }
    return inputFs.open(path);
  } catch (IOException e) {
    LOG.error("Unable to open source file=" + path, e);
    return null;
  }
}
项目：hindex    文件：SnapshotInfo.java    
/**
 * Add the specified log file to the stats
 * @param server server name
 * @param logfile log file name
 * @return the log information
 */
FileInfo addLogFile(final String server, final String logfile) throws IOException {
  HLogLink logLink = new HLogLink(conf, server, logfile);
  long size = -1;
  try {
    size = logLink.getFileStatus(fs).getLen();
    logSize += size;
    logsCount++;
  } catch (FileNotFoundException e) {
    logsMissing++;
  }
  return new FileInfo(false, size);
}
项目：LCIndex-HBase-0.94.16    文件：SnapshotLogSplitter.java    
public void splitLog(final String serverName, final String logfile) throws IOException {
  LOG.debug("Restore log=" + logfile + " server=" + serverName +
            " for snapshotTable=" + Bytes.toString(snapshotTableName) +
            " to table=" + Bytes.toString(tableName));
  splitLog(new HLogLink(conf, serverName, logfile).getAvailablePath(fs));
}
项目：HIndex    文件：SnapshotLogSplitter.java    
public void splitLog(final String serverName, final String logfile) throws IOException {
  LOG.debug("Restore log=" + logfile + " server=" + serverName +
            " for snapshotTable=" + snapshotTableName +
            " to table=" + tableName);
  splitLog(new HLogLink(conf, serverName, logfile).getAvailablePath(fs));
}
项目：IRIndex    文件：SnapshotLogSplitter.java    
public void splitLog(final String serverName, final String logfile) throws IOException {
  LOG.debug("Restore log=" + logfile + " server=" + serverName +
            " for snapshotTable=" + Bytes.toString(snapshotTableName) +
            " to table=" + Bytes.toString(tableName));
  splitLog(new HLogLink(conf, serverName, logfile).getAvailablePath(fs));
}
项目：c5    文件：SnapshotLogSplitter.java    
public void splitLog(final String serverName, final String logfile) throws IOException {
  LOG.debug("Restore log=" + logfile + " server=" + serverName +
            " for snapshotTable=" + snapshotTableName +
            " to table=" + tableName);
  splitLog(new HLogLink(conf, serverName, logfile).getAvailablePath(fs));
}
项目：HBase-Research    文件：SnapshotLogSplitter.java    
public void splitLog(final String serverName, final String logfile) throws IOException {
  LOG.debug("Restore log=" + logfile + " server=" + serverName +
            " for snapshotTable=" + Bytes.toString(snapshotTableName) +
            " to table=" + Bytes.toString(tableName));
  splitLog(new HLogLink(conf, serverName, logfile).getAvailablePath(fs));
}
项目：hbase-0.94.8-qod    文件：SnapshotLogSplitter.java    
public void splitLog(final String serverName, final String logfile) throws IOException {
  LOG.debug("Restore log=" + logfile + " server=" + serverName +
            " for snapshotTable=" + Bytes.toString(snapshotTableName) +
            " to table=" + Bytes.toString(tableName));
  splitLog(new HLogLink(conf, serverName, logfile).getAvailablePath(fs));
}
项目：hbase-0.94.8-qod    文件：SnapshotLogSplitter.java    
public void splitLog(final String serverName, final String logfile) throws IOException {
  LOG.debug("Restore log=" + logfile + " server=" + serverName +
            " for snapshotTable=" + Bytes.toString(snapshotTableName) +
            " to table=" + Bytes.toString(tableName));
  splitLog(new HLogLink(conf, serverName, logfile).getAvailablePath(fs));
}
项目：hindex    文件：SnapshotLogSplitter.java    
public void splitLog(final String serverName, final String logfile) throws IOException {
  LOG.debug("Restore log=" + logfile + " server=" + serverName +
            " for snapshotTable=" + Bytes.toString(snapshotTableName) +
            " to table=" + Bytes.toString(tableName));
  splitLog(new HLogLink(conf, serverName, logfile).getAvailablePath(fs));
}