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);*

Reply via email to