java - Setting custom file format class in mapreduce job -
i extended fileinputformat xmlfileinputformat. problem when set class on job
job.setinputformatclass(xmlfileinputformat.class); i error telling expects class extend or.apache.hadoop.mapreduce.inputformat (but checked fileinputformat implements inputformat)
this class set way
public class xmlfileinputformat extends fileinputformat<nullwritable, byteswritable> { @override protected boolean issplitable(filesystem fs, path filename) { return false; } @override public recordreader<nullwritable, byteswritable> getrecordreader( inputsplit split, jobconf job, reporter reporter) throws ioexception { return new xmlfilerecordreader((filesplit) split, job); } } how can set correctly inputformat ?
please verify package structure in import statement. should org.apache.hadoop.mapreduce.fileinputformat.
you have imported: org.apache.hadoop.mapred.fileinputformat
Comments
Post a Comment