MapReduce高级编程之自定义InputFormat

日期：2020-09-21 栏目：程序人生浏览：次

public interface InputFormat<K, V> {
InputSplit[]getSplits(JobConf job, int numSplits) throws IOException;
RecordReader<K, V>getRecordReader(InputSplit split,
JobConf job,
Reporter reporter) throws IOException;
}