Hi,
I'm trying to write my JavaPairRDD using saveAsNewAPIHadoopFile with
MultipleTextOutputFormat,:
outRdd.saveAsNewAPIHadoopFile("/tmp", String.class, String.class,
MultipleTextOutputFormat.class);
but I'm getting this compilation error:
Bound mismatch: The generic method saveAsNewAPIHadoopFile(String,
Class<?>, Class<?>, Class<F>) of type JavaPairRDD<K,V> is not
applicable for the arguments (String, Class<String>, Class<String>,
Class<MultipleTextOutputFormat>). The inferred type
MultipleTextOutputFormat is not a valid substitute for the bounded
parameter <F extends OutputFormat<?,?>>
I bumped into some discussions suggesting to use MultipleOutputs
(http://hadoop.apache.org/docs/r2.3.0/api/org/apache/hadoop/mapreduce/lib/output/MultipleOutputs.html),
but this also fails from the same reason.
Would love some assistance :)
Thanks,
Tomer
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
