!rdd.isEmpty() should work but an alternative could be rdd.take(1) != 0
> On Feb 16, 2016, at 9:33 AM, Ashutosh Kumar <kmr.ashutos...@gmail.com> wrote:
>
> I am getting multiple empty files for streaming output for each interval.
> To Avoid this I tried
>
> kStream.foreachRDD(new VoidFunction2<JavaRDD<String>,Time>(){
> public void call(JavaRDD<String> rdd,Time time) throws Exception {
> if(!rdd.isEmpty()){
>
> rdd.saveAsTextFile("filename_"+time.milliseconds()+".csv");
> }
> }
>
> This prevents writing of empty files. However this appends line after one
> another by removing new lines. All lines are merged.
> How do I retain my new line?
>
> Thanks
