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

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class SequenceFileInputFormat<K,V>
extends FileInputFormat<K,V>

An InputFormat for SequenceFiles.

フィールドのサマリー

クラスから継承されたフィールド 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

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

コンストラクタ

コンストラクタと説明
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, 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

コンストラクタの詳細

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.