org.apache.hadoop.mapred

类 SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader

java.lang.Object

org.apache.hadoop.mapred.SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader

所有已实现的接口:

RecordReader<BytesWritable,BytesWritable>

封闭类:

SequenceFileAsBinaryInputFormat

public static class SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader
extends Object
implements RecordReader<BytesWritable,BytesWritable>

Read records from a SequenceFile as binary (raw) bytes.

构造器概要

构造器

构造器和说明
SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader(Configuration conf, FileSplit split)

方法概要

方法

限定符和类型	方法和说明
void	close() Close this InputSplit to future operations.
BytesWritable	createKey() Create an object of the appropriate type to be used as a key.
BytesWritable	createValue() Create an object of the appropriate type to be used as a value.
String	getKeyClassName() Retrieve the name of the key class for this SequenceFile.
long	getPos() Returns the current position in the input.
float	getProgress() Return the progress within the input split
String	getValueClassName() Retrieve the name of the value class for this SequenceFile.
boolean	next(BytesWritable key, BytesWritable val) Read raw bytes from a SequenceFile.

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

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

构造器详细资料

SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader

public SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader(Configuration conf,
                                                                FileSplit split)
                                                                 throws IOException

抛出:

IOException

方法详细资料

createKey

public BytesWritable createKey()

从接口复制的说明: RecordReader

Create an object of the appropriate type to be used as a key.

指定者:

createKey 在接口中 RecordReader<BytesWritable,BytesWritable>

返回:

a new key object.

createValue

public BytesWritable createValue()

从接口复制的说明: RecordReader

Create an object of the appropriate type to be used as a value.

指定者:

createValue 在接口中 RecordReader<BytesWritable,BytesWritable>

返回:

a new value object.

getKeyClassName

public String getKeyClassName()

Retrieve the name of the key class for this SequenceFile.

另请参阅:

SequenceFile.Reader.getKeyClassName()

getValueClassName

public String getValueClassName()

Retrieve the name of the value class for this SequenceFile.

另请参阅:

SequenceFile.Reader.getValueClassName()

next

public boolean next(BytesWritable key,
           BytesWritable val)
             throws IOException

Read raw bytes from a SequenceFile.

指定者:

next 在接口中 RecordReader<BytesWritable,BytesWritable>

参数:

key - the key to read data into

val - the value to read data into

返回:

true iff a key/value was read, false if at EOF

抛出:

IOException

getPos

public long getPos()
            throws IOException

从接口复制的说明: RecordReader

Returns the current position in the input.

指定者:

getPos 在接口中 RecordReader<BytesWritable,BytesWritable>

返回:

the current position in the input.

抛出:

IOException

close

public void close()
           throws IOException

从接口复制的说明: RecordReader

Close this InputSplit to future operations.

指定者:

close 在接口中 RecordReader<BytesWritable,BytesWritable>

抛出:

IOException

getProgress

public float getProgress()
                  throws IOException

Return the progress within the input split

指定者:

getProgress 在接口中 RecordReader<BytesWritable,BytesWritable>

返回:

0.0 to 1.0 of the input byte range

抛出:

IOException