Please help as not sure what is incorrect with below code as it gives me complilaton error in eclipse
SparkConf sparkConf = new SparkConf().setMaster("local[4]").setAppName("JavaDirectKafkaWordCount"); JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, Durations.seconds(2)); * jssc.fileStream("/home/", String.class, String.class, TextInputFormat.class);*