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

ZKSplitLog.isCorrupted介绍

暂无

代码示例

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

private static void finishSplitLogFile(Path walDir, Path oldLogDir,
  Path logPath, Configuration conf) throws IOException {
 List<Path> processedLogs = new ArrayList<>();
 List<Path> corruptedLogs = new ArrayList<>();
 FileSystem walFS = walDir.getFileSystem(conf);
 if (ZKSplitLog.isCorrupted(walDir, logPath.getName(), walFS)) {
  corruptedLogs.add(logPath);
 } else {
  processedLogs.add(logPath);
 }
 archiveLogs(corruptedLogs, processedLogs, oldLogDir, walFS, conf);
 Path stagingDir = ZKSplitLog.getSplitLogDir(walDir, logPath.getName());
 walFS.delete(stagingDir, true);
}

代码示例来源：origin: co.cask.hbase/hbase

public static void finishSplitLogFile(Path rootdir, Path oldLogDir,
  String logfile, Configuration conf) throws IOException {
 List<Path> processedLogs = new ArrayList<Path>();
 List<Path> corruptedLogs = new ArrayList<Path>();
 FileSystem fs;
 fs = rootdir.getFileSystem(conf);
 Path logPath = new Path(logfile);
 if (ZKSplitLog.isCorrupted(rootdir, logPath.getName(), fs)) {
  corruptedLogs.add(logPath);
 } else {
  processedLogs.add(logPath);
 }
 archiveLogs(null, corruptedLogs, processedLogs, oldLogDir, fs, conf);
 Path stagingDir = ZKSplitLog.getSplitLogDir(rootdir, logPath.getName());
 fs.delete(stagingDir, true);
}

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

static void finishSplitLogFile(Path rootdir, Path oldLogDir,
  Path logPath, Configuration conf) throws IOException {
 List<Path> processedLogs = new ArrayList<Path>();
 List<Path> corruptedLogs = new ArrayList<Path>();
 FileSystem fs;
 fs = rootdir.getFileSystem(conf);
 if (ZKSplitLog.isCorrupted(rootdir, logPath.getName(), fs)) {
  corruptedLogs.add(logPath);
 } else {
  processedLogs.add(logPath);
 }
 archiveLogs(corruptedLogs, processedLogs, oldLogDir, fs, conf);
 Path stagingDir = ZKSplitLog.getSplitLogDir(rootdir, logPath.getName());
 fs.delete(stagingDir, true);
}