import org.apache.hadoop.io .{LongWritable, MapWritable}

val path = "hdfs://hadoop-master:9000/user/root/fichierros.bag" val inputFormatClass = classOf[io.autovia.foss.RosbagMapInputFormat] val keyClass = classOf[LongWritable] val valueClass = classOf[MapWritable] val conf = new org.apache.hadoop.conf.Configuration() conf.set(“RosbagInputFormat.chunkIdx”, “hdfs://hadoop-master:9000/user/root/fichierros.bag.idx.bin”) val rdd = sc.newAPIHadoopFile(chemin, inputFormatClass, keyClass, valueClass, conf)

J'ai les mêmes erreurs dans ce code java.io.FileNotFoundException: hdfs:/hadoop-master:9000/fichier_ros.bag.idx.bin (Aucun fichier ou répertoire de ce type)

plz j'ai besoin de créer RDD en étincelle avec fille rosbag si vous avez les mêmes idées