Commit bfbc3fa6 authored by Ihrig, Arvid Conrad (ari)'s avatar Ihrig, Arvid Conrad (ari)
Browse files

Integrated Pipeline: refactored ArchiveHandling now used in main code

parent cbbc7eb1
......@@ -135,9 +135,15 @@ class Main {
}
})
val archiveHandler = new ArchiveHandler(tempExtracted)
val unpacker = Flow.fromGraph(new ArchiveUnpackingFlow(archiveHandler))
val cleanUp = Flow.fromGraph(new ArchiveCleanUpFlow(archiveHandler))
val archiveHandler = new WholeZipArchiveHandler(new ArchiveHandler(tempExtracted))
val unpacker = Flow.fromGraph(new MessageProcessorFlow[TreeScanSignal, TreeScanSignal] {
override val stageName = "Zip-Archive-Unpacker"
override val processor = new ArchiveUnpacker(archiveHandler)
})
val cleanUp = Flow.fromGraph(new MessageProcessorFlow[FileParsingSignal, FileParsingSignal] {
override val stageName = "Zip-Archive-CleanUp"
override val processor = new ArchiveCleanUp(archiveHandler)
})
val parsing = CalculationParsingFlow.createParsingFlow(
(1 to params.numWorkers).map(i =>
new CalculationParsingEngine(Main.parsers, metaInfo, eventProcessor, Some(f"Worker-$i%2d")))
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment