spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ashish Soni <asoni.le...@gmail.com>
Subject Java Streaming Context - File Stream use
Date Mon, 10 Aug 2015 19:40:37 GMT
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);*

Mime
View raw message