This commit is contained in:
Nofel Yaseen 2020-10-04 15:59:14 -04:00
Родитель 5fc13e0dc3
Коммит 38acd0f5c7
1 изменённых файлов: 1 добавлений и 1 удалений

Просмотреть файл

@ -225,7 +225,7 @@ public class Verifier {
}
} else if (mode == Mode.STANDALONE_FILE || mode == Mode.LOCAL_FILE) {
parsedPackets = env.readTextFile(inputPath).setParallelism(1)
.flatMap(ParserFactory.createNewParser(parser)).setParallelism(1);
.flatMap(ParserFactory.createNewParser(parser, formatFile, delimiter)).setParallelism(1);
} else if (mode == Mode.STANDALONE_FOLDER || mode == Mode.LOCAL_FOLDER) {
parsedPacketsDict = new HashMap<String, ArrayList<DataStream<Packet>>>();
File[] inFolder = (new File(inputPath)).listFiles();