org.apache.hadoop.mapreduce.lib.input

类 SequenceFileInputFormat<K,V>

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<K,V>

org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>

org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat<K,V>

直接已知子类:

SequenceFileAsBinaryInputFormat, SequenceFileAsTextInputFormat, SequenceFileInputFilter

public class SequenceFileInputFormat<K,V>
extends FileInputFormat<K,V>

An InputFormat for SequenceFiles.

嵌套类概要

从类继承的嵌套类/接口 org.apache.hadoop.mapreduce.lib.input.FileInputFormat

FileInputFormat.Counter

构造器概要

构造器

构造器和说明
SequenceFileInputFormat()

方法概要

方法

限定符和类型	方法和说明
RecordReader<K,V>	createRecordReader(InputSplit split, TaskAttemptContext context) Create a record reader for a given split.
protected long	getFormatMinSplitSize() Get the lower bound on split size imposed by the format.
protected List<FileStatus>	listStatus(JobContext job) List input directories.

从类继承的方法 org.apache.hadoop.mapreduce.lib.input.FileInputFormat

addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, isSplitable, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize

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

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

构造器详细资料

SequenceFileInputFormat

public SequenceFileInputFormat()

方法详细资料

createRecordReader

public RecordReader<K,V> createRecordReader(InputSplit split,
                                   TaskAttemptContext context)
                                     throws IOException

从类复制的说明: InputFormat

Create a record reader for a given split. The framework will call RecordReader.initialize(InputSplit, TaskAttemptContext) before the split is used.

指定者:

createRecordReader 在类中 InputFormat<K,V>

参数:

split - the split to be read

context - the information about the task

返回:

a new record reader

抛出:

IOException

getFormatMinSplitSize

protected long getFormatMinSplitSize()

从类复制的说明: FileInputFormat

Get the lower bound on split size imposed by the format.

覆盖:

getFormatMinSplitSize 在类中 FileInputFormat<K,V>

返回:

the number of bytes of the minimal split for this format

listStatus

protected List<FileStatus> listStatus(JobContext job)
                               throws IOException

从类复制的说明: FileInputFormat

List input directories. Subclasses may override to, e.g., select only files matching a regular expression.

覆盖:

listStatus 在类中 FileInputFormat<K,V>

参数:

job - the job to list input paths for

返回:

array of FileStatus objects

抛出:

IOException - if zero items.