org.apache.hadoop.mapreduce.lib.input

类 SequenceFileAsBinaryInputFormat

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<BytesWritable,BytesWritable>

org.apache.hadoop.mapreduce.lib.input.SequenceFileAsBinaryInputFormat

@InterfaceAudience.Public
@InterfaceStability.Stable
public class SequenceFileAsBinaryInputFormat
extends SequenceFileInputFormat<BytesWritable,BytesWritable>

InputFormat reading keys, values from SequenceFiles in binary (raw) format.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader Read records from a SequenceFile as binary (raw) bytes.

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

FileInputFormat.Counter

构造器概要

构造器

构造器和说明
SequenceFileAsBinaryInputFormat()

方法概要

方法

限定符和类型	方法和说明
RecordReader<BytesWritable,BytesWritable>	createRecordReader(InputSplit split, TaskAttemptContext context) Create a record reader for a given split.

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

getFormatMinSplitSize, listStatus

从类继承的方法 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

构造器详细资料

SequenceFileAsBinaryInputFormat

public SequenceFileAsBinaryInputFormat()

方法详细资料

createRecordReader

public RecordReader<BytesWritable,BytesWritable> 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 在类中 SequenceFileInputFormat<BytesWritable,BytesWritable>

参数:

split - the split to be read

context - the information about the task

返回:

a new record reader

抛出:

IOException