org.apache.hadoop.mapred.join

接口 ComposableInputFormat<K extends WritableComparable,V extends Writable>

所有超级接口:

InputFormat<K,V>

所有已知实现类:

CompositeInputFormat, Parser.Node

public interface ComposableInputFormat<K extends WritableComparable,V extends Writable>
extends InputFormat<K,V>

Refinement of InputFormat requiring implementors to provide ComposableRecordReader instead of RecordReader.

方法概要

方法

限定符和类型	方法和说明
ComposableRecordReader<K,V>	getRecordReader(InputSplit split, JobConf job, Reporter reporter) Get the RecordReader for the given InputSplit.

从接口继承的方法 org.apache.hadoop.mapred.InputFormat

getSplits

方法详细资料

getRecordReader

ComposableRecordReader<K,V> getRecordReader(InputSplit split,
                                          JobConf job,
                                          Reporter reporter)
                                                                                        throws IOException

从接口复制的说明: InputFormat

Get the RecordReader for the given InputSplit.

It is the responsibility of the RecordReader to respect record boundaries while processing the logical split to present a record-oriented view to the individual task.

指定者:

getRecordReader 在接口中 InputFormat<K extends WritableComparable,V extends Writable>

参数:

split - the InputSplit

job - the job that this split belongs to

返回:

a RecordReader

抛出:

IOException