in core/src/main/java/org/apache/sdap/mudrod/weblog/pre/ImportLogFile.java [117:146]
private void readFile() {
String httplogpath = null;
String ftplogpath = null;
File directory = new File(props.getProperty(MudrodConstants.DATA_DIR));
File[] fList = directory.listFiles();
for (File file : fList) {
if (file.isFile() && file.getName().contains(props.getProperty(MudrodConstants.TIME_SUFFIX)))
{
if (file.getName().contains(props.getProperty(MudrodConstants.HTTP_PREFIX)))
{
httplogpath = file.getAbsolutePath();
}
if (file.getName().contains(props.getProperty(MudrodConstants.FTP_PREFIX)))
{
ftplogpath = file.getAbsolutePath();
}
}
}
if(httplogpath == null || ftplogpath == null)
{
LOG.error("WWW file or FTP logs cannot be found, please check your data directory.");
return;
}
readFileInParallel(httplogpath, ftplogpath);
}