我上课了 ImageInputFormat 在Hadoop中从HDFS读取图像。如何在Spark中使用我的InputFormat？
这是我的 ImageInputFormat：
public class ImageInputFormat extends FileInputFormat<Text, ImageWritable> {
@Override
public ImageRecordReader createRecordReader(InputSplit split,
TaskAttemptContext context) throws IOException, InterruptedException {
return new ImageRecordReader();
}
@Override
protected boolean isSplitable(JobContext context, Path filename) {
return false;
}
}