Details
-
Improvement
-
Status: Resolved
-
Trivial
-
Resolution: Fixed
-
None
Description
Currently, every pipeline invokes dataFrame.write.mode.parquet to save results in HDFS. To all the *SuspiciousConnectsAnalysis.scala free of that method call, we can return a couple of data frames to SuspiciousConnects.scala and from there save results.
With that, we are going to be able to write unit tests for *SuspiciousConnectsAnalysis.run method.