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.

フィールドのサマリー

クラスから継承されたフィールド org.apache.hadoop.mapreduce.lib.input.FileInputFormat

DEFAULT_LIST_STATUS_NUM_THREADS, INPUT_DIR, INPUT_DIR_RECURSIVE, LIST_STATUS_NUM_THREADS, NUM_INPUT_FILES, PATHFILTER_CLASS, SPLIT_MAXSIZE, SPLIT_MINSIZE

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
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, addInputPathRecursively, addInputPaths, computeSplitSize, getBlockIndex, getInputDirRecursive, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, isSplitable, makeSplit, makeSplit, setInputDirRecursive, 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