Modify HibRecodReader to support Spark!
so Spark Driver code Declare hadoopConfuration variable is "imagetype" ， for example:
val conf = new SparkConf()
val sc = new SparkContext("local", "HipiDemo", conf)
val hconf = sc.hadoopConfiguration
hconf.set("fs.defaultFS", "hdfs://honest:8020")
hconf.set("imagetype","FloatImage")
val aa = sc.newAPIHadoopFileHipiImageHeader,HipiImage,HibInputFormat
aa.saveAsNewAPIHadoopFile("hdfs://honest:8020/dw4",
classOf[NullWritable],classOf[OpenCVMatWritable],classOf[BinaryOutputFormat[NullWritable, OpenCVMatWritable]])
Modify HibRecodReader to support Spark! so Spark Driver code Declare hadoopConfuration variable is "imagetype" ， for example: val conf = new SparkConf() val sc = new SparkContext("local", "HipiDemo", conf) val hconf = sc.hadoopConfiguration hconf.set("fs.defaultFS", "hdfs://honest:8020") hconf.set("imagetype","FloatImage") val aa = sc.newAPIHadoopFileHipiImageHeader,HipiImage,HibInputFormat aa.saveAsNewAPIHadoopFile("hdfs://honest:8020/dw4", classOf[NullWritable],classOf[OpenCVMatWritable],classOf[BinaryOutputFormat[NullWritable, OpenCVMatWritable]])