org.apache.hadoop.mapred

类 TextInputFormat

java.lang.Object

org.apache.hadoop.mapred.FileInputFormat<LongWritable,Text>

org.apache.hadoop.mapred.TextInputFormat

所有实现的接口：

InputFormat<LongWritable,Text>, JobConfigurable

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class TextInputFormat
extends FileInputFormat<LongWritable,Text>
implements JobConfigurable

用于纯文本文件的InputFormat。文件被分割成行，使用换行符或回车符表示行结束。键是文件中的位置，值是文本行。

字段摘要

从类 org.apache.hadoop.mapred.FileInputFormat 继承的字段

INPUT_DIR_NONRECURSIVE_IGNORE_SUBDIRS, INPUT_DIR_RECURSIVE, LOG, NUM_INPUT_FILES

构造函数摘要

构造函数及描述
TextInputFormat()

方法摘要

修饰符和类型	方法和描述
void	configure(JobConf conf) Initializes a new instance from a JobConf.
RecordReader<LongWritable,Text>	getRecordReader(InputSplit genericSplit, JobConf job, Reporter reporter) Get the RecordReader for the given InputSplit.
protected boolean	isSplitable(FileSystem fs, Path file) 给定的文件名是否可分割？通常情况下是可以的，但如果文件是流式压缩的，则不可分割。

从org.apache.hadoop.mapred.FileInputFormat类继承的方法

addInputPath, addInputPathRecursively, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getSplitHosts, getSplits, listStatus, makeSplit, makeSplit, setInputPathFilter, setInputPaths, setInputPaths, setMinSplitSize

从java.lang.Object类继承的方法

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造函数详情

TextInputFormat

public TextInputFormat()

方法详情

configure

public void configure(JobConf conf)

从接口复制的描述: JobConfigurable

从JobConf初始化一个新实例。

指定者:

configure 在接口中 JobConfigurable

参数:

conf - 配置信息

isSplitable

protected boolean isSplitable(FileSystem fs,
                              Path file)

从类复制的描述: FileInputFormat

给定的文件名是否可分割？通常返回true，但如果文件是流式压缩的，则不可分割。 FileInputFormat中的默认实现总是返回true。需要处理不可分割文件的实现必须重写此方法。 FileInputFormat的实现可以重写此方法并返回false，以确保单个输入文件永远不会被分割，从而使Mapper处理完整的文件。

覆盖:

isSplitable 在类中 FileInputFormat<LongWritable,Text>

参数:

fs - 文件所在的文件系统

file - 要检查的文件名

返回:

该文件是否可分割？

getRecordReader

public RecordReader<LongWritable,Text> getRecordReader(InputSplit genericSplit,
                                                       JobConf job,
                                                       Reporter reporter)
                                                throws IOException

从接口复制的描述: InputFormat

获取给定InputSplit的RecordReader。

RecordReader的职责是在处理逻辑分片时保持记录边界，为单个任务提供面向记录的视图。

指定者:

getRecordReader 在接口 InputFormat<LongWritable,Text>

指定者:

getRecordReader 在类 FileInputFormat<LongWritable,Text>

参数:

genericSplit - 该InputSplit

job - 此分片所属的作业

返回:

一个RecordReader

抛出:

IOException