Hi, I am facing issues while writing data from a streaming rdd to hdfs.. JavaPairDstream<String,String> temp; ... ... temp.saveAsHadoopFiles("DailyCSV",".txt", String.class, String.class,TextOutputFormat.class);
I see compilation issues as below... The method saveAsHadoopFiles(String, String, Class<?>, Class<?>, Class<? extends OutputFormat<?,?>>) in the type JavaPairDStream<String,String> is not applicable for the arguments (String, String, Class<String>, Class<String>, Class<TextOutputFormat>) I see same kind of problem even with saveAsNewAPIHadoopFiles API . Thanks, Baahu