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

Reply via email to