java - hadoop上的自定义类FileInputFormat

Question

我正在hadoop上运行WordCount示例，我想读取文件的全部内容。我使用了here中的示例(WholeFileInputFormat-NewAPI.java和WholeFileRecordReader-NewAPI.java)。我在WordCount类中添加了以下内容:conf.setInputFormat(WholeFileInputFormat.class);

当我编译程序时，出现以下错误:

 error: method setInputFormat in class JobConf cannot be applied to given types;
        conf.setInputFormat(WholeFileInputFormat.class);
            ^
  required: Class<? extends InputFormat>
  found: Class<WholeFileInputFormat>
  reason: argument mismatch; Class<WholeFileInputFormat> cannot be converted to Class<?   extends InputFormat>

谢谢你的帮助。

Answer 1

也许您正在使用旧的API，而WholeFileInputFormat是新的API。您也应该使用新的API。