Re: Problem with File Streams

2015-01-17 Thread Akhil Das
Try: JavaPairDStreamString, String foo = ssc.String, String, SequenceFileInputFormatfileStream(/sigmoid/foo); Thanks Best Regards On Sat, Jan 17, 2015 at 4:24 AM, Leonidas Fegaras fega...@cse.uta.edu wrote: Dear Spark users, I have a problem using File Streams in Java on Spark 1.2.0. I can

Re: Problem with File Streams

2015-01-17 Thread Leonidas Fegaras
); Thanks Best Regards On Sat, Jan 17, 2015 at 4:24 AM, Leonidas Fegaras fega...@cse.uta.edu mailto:fega...@cse.uta.edu wrote: Dear Spark users, I have a problem using File Streams in Java on Spark 1.2.0. I can process hadoop files in local mode using: spark_context.newAPIHadoopFile