Run Code | API | Code Wall | Misc | Feedback | Login | Theme | Privacy | Patreon |
why this errorError(s), warning(s): source_file.scala:20: error: not found: type SparkConf val sparkConf=new SparkConf().setAppName("KafkaWordCount").setMaster("local[2]") ^ source_file.scala:22: error: not found: type StreamingContext val ssc=new StreamingContext(sparkConf,Seconds(20)) ^ source_file.scala:22: error: not found: value Seconds val ssc=new StreamingContext(sparkConf,Seconds(20)) ^ source_file.scala:34: error: not found: value KafkaUtils val lines = KafkaUtils.createStream[Array[Byte],String,DefaultDecoder,DefaultDecoder] ( ^ source_file.scala:34: error: not found: type DefaultDecoder val lines = KafkaUtils.createStream[Array[Byte],String,DefaultDecoder,DefaultDecoder] ( ^ source_file.scala:34: error: not found: type DefaultDecoder val lines = KafkaUtils.createStream[Array[Byte],String,DefaultDecoder,DefaultDecoder] ( ^ source_file.scala:39: error: not found: value StorageLevel StorageLevel.MEMORY_ONLY ^ 7 errors found |
λ
.NET NoSQL database for rapid development
|