import org.apache.hadoop.hdfs.server.datanode.fsdataset.RollingLogs; //导入依赖的package包/类
@Override
public RollingLogs createRollingLogs(String bpid, String prefix
    ) throws IOException {
  String dir = null;
  final List<FsVolumeImpl> volumes = getVolumes();
  for (FsVolumeImpl vol : volumes) {
    String bpDir = vol.getPath(bpid);
    if (RollingLogsImpl.isFilePresent(bpDir, prefix)) {
      dir = bpDir;
      break;
    }
  }
  if (dir == null) {
    dir = volumes.get(0).getPath(bpid);
  }
  return new RollingLogsImpl(dir, prefix);
}
 

import org.apache.hadoop.hdfs.server.datanode.fsdataset.RollingLogs; //导入依赖的package包/类
@Override
public RollingLogs createRollingLogs(String bpid, String prefix)
    throws IOException {
  String dir = null;
  final List<FsVolumeImpl> volumes = getVolumes();
  for (FsVolumeImpl vol : volumes) {
    String bpDir = vol.getPath(bpid);
    if (RollingLogsImpl.isFilePresent(bpDir, prefix)) {
      dir = bpDir;
      break;
    }
  }
  if (dir == null) {
    dir = volumes.get(0).getPath(bpid);
  }
  return new RollingLogsImpl(dir, prefix);
}
 

import org.apache.hadoop.hdfs.server.datanode.fsdataset.RollingLogs; //导入依赖的package包/类
private LogFileHandler(RollingLogs logs)  {
  this.logs = logs;
}
 

import org.apache.hadoop.hdfs.server.datanode.fsdataset.RollingLogs; //导入依赖的package包/类
@Override
public RollingLogs createRollingLogs(String bpid, String prefix) {
  throw new UnsupportedOperationException();
}
 

import org.apache.hadoop.hdfs.server.datanode.fsdataset.RollingLogs; //导入依赖的package包/类
private LogFileHandler(RollingLogs logs) {
  this.logs = logs;
}