Run Code  | API  | Code Wall  | Misc  | Feedback  | Login  | Theme  | Privacy  | Patreon 

why this error

Language: Layout:
+ ] Show input
Compilation time: 0.62 sec, absolute service time: 0,63 sec 
edit mode |  history  | discussion
Error(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