[NOTICKET] Overall project enhancements
- Everything on
ch/cern/monitoring
was moved toch/cern/monitoring/utilities
to match the package declarations. - The method
writeStream
onKafkaUtils
was changed to:- Return a
StreamingQuery
instead of aUnit
- Configure the
outputMode
which can be passed as a parameter (defaults toAppend
as before)
- Return a
- A few changes recommend by IntelliJ were carried out to:
- Remove redundancies/unused imports
- Adhere to Scala's coding style