Cleaned SparkStreamProcessor class