org.apache.hadoop.io.file.tfile

类 TFile.Reader.Scanner

java.lang.Object

org.apache.hadoop.io.file.tfile.TFile.Reader.Scanner

所有已实现的接口:

Closeable, AutoCloseable

封闭类:

TFile.Reader

public static class TFile.Reader.Scanner
extends Object
implements Closeable

The TFile Scanner. The Scanner has an implicit cursor, which, upon creation, points to the first key-value pair in the scan range. If the scan range is empty, the cursor will point to the end of the scan range.

Use atEnd() to test whether the cursor is at the end location of the scanner.

Use advance() to move the cursor to the next key-value pair (or end if none exists). Use seekTo methods ( seekTo(byte[]) or seekTo(byte[], int, int)) to seek to any arbitrary location in the covered range (including backward seeking). Use rewind() to seek back to the beginning of the scanner. Use seekToEnd() to seek to the end of the scanner.

Actual keys and values may be obtained through TFile.Reader.Scanner.Entry object, which is obtained through entry().

嵌套类概要

嵌套类

限定符和类型	类和说明
class	TFile.Reader.Scanner.Entry Entry to a <Key, Value> pair.

构造器概要

构造器

限定符	构造器和说明
protected	TFile.Reader.Scanner(TFile.Reader reader, long offBegin, long offEnd) Constructor
protected	TFile.Reader.Scanner(TFile.Reader reader, RawComparable beginKey, RawComparable endKey) Constructor

方法概要

方法

限定符和类型	方法和说明
boolean	advance() Move the cursor to the next key-value pair.
boolean	atEnd() Is cursor at the end location?
void	close() Close the scanner.
TFile.Reader.Scanner.Entry	entry() Get an entry to access the key and value.
long	getRecordNum() Get the RecordNum corresponding to the entry pointed by the cursor.
void	lowerBound(byte[] key) Move the cursor to the first entry whose key is greater than or equal to the input key.
void	lowerBound(byte[] key, int keyOffset, int keyLen) Move the cursor to the first entry whose key is greater than or equal to the input key.
void	rewind() Rewind to the first entry in the scanner.
boolean	seekTo(byte[] key) Move the cursor to the first entry whose key is greater than or equal to the input key.
boolean	seekTo(byte[] key, int keyOffset, int keyLen) Move the cursor to the first entry whose key is greater than or equal to the input key.
void	seekToEnd() Seek to the end of the scanner.
void	upperBound(byte[] key) Move the cursor to the first entry whose key is strictly greater than the input key.
void	upperBound(byte[] key, int keyOffset, int keyLen) Move the cursor to the first entry whose key is strictly greater than the input key.

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

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

构造器详细资料

TFile.Reader.Scanner

protected TFile.Reader.Scanner(TFile.Reader reader,
                    long offBegin,
                    long offEnd)
                        throws IOException

Constructor

参数:

reader - The TFile reader object.

offBegin - Begin byte-offset of the scan.

offEnd - End byte-offset of the scan.

抛出:

IOException - The offsets will be rounded to the beginning of a compressed block whose offset is greater than or equal to the specified offset.

TFile.Reader.Scanner

protected TFile.Reader.Scanner(TFile.Reader reader,
                    RawComparable beginKey,
                    RawComparable endKey)
                        throws IOException

Constructor

参数:

reader - The TFile reader object.

beginKey - Begin key of the scan. If null, scan from the first entry of the TFile.

endKey - End key of the scan. If null, scan up to the last entry of the TFile.

抛出:

IOException

方法详细资料

seekTo

public boolean seekTo(byte[] key)
               throws IOException

Move the cursor to the first entry whose key is greater than or equal to the input key. Synonymous to seekTo(key, 0, key.length). The entry returned by the previous entry() call will be invalid.

参数:

key - The input key

返回:

true if we find an equal key.

抛出:

IOException

seekTo

public boolean seekTo(byte[] key,
             int keyOffset,
             int keyLen)
               throws IOException

Move the cursor to the first entry whose key is greater than or equal to the input key. The entry returned by the previous entry() call will be invalid.

参数:

key - The input key

keyOffset - offset in the key buffer.

keyLen - key buffer length.

返回:

true if we find an equal key; false otherwise.

抛出:

IOException

rewind

public void rewind()
            throws IOException

Rewind to the first entry in the scanner. The entry returned by the previous entry() call will be invalid.

抛出:

IOException

seekToEnd

public void seekToEnd()
               throws IOException

Seek to the end of the scanner. The entry returned by the previous entry() call will be invalid.

抛出:

IOException

lowerBound

public void lowerBound(byte[] key)
                throws IOException

Move the cursor to the first entry whose key is greater than or equal to the input key. Synonymous to lowerBound(key, 0, key.length). The entry returned by the previous entry() call will be invalid.

参数:

key - The input key

抛出:

IOException

lowerBound

public void lowerBound(byte[] key,
              int keyOffset,
              int keyLen)
                throws IOException

Move the cursor to the first entry whose key is greater than or equal to the input key. The entry returned by the previous entry() call will be invalid.

参数:

key - The input key

keyOffset - offset in the key buffer.

keyLen - key buffer length.

抛出:

IOException

upperBound

public void upperBound(byte[] key)
                throws IOException

Move the cursor to the first entry whose key is strictly greater than the input key. Synonymous to upperBound(key, 0, key.length). The entry returned by the previous entry() call will be invalid.

参数:

key - The input key

抛出:

IOException

upperBound

public void upperBound(byte[] key,
              int keyOffset,
              int keyLen)
                throws IOException

Move the cursor to the first entry whose key is strictly greater than the input key. The entry returned by the previous entry() call will be invalid.

参数:

key - The input key

keyOffset - offset in the key buffer.

keyLen - key buffer length.

抛出:

IOException

advance

public boolean advance()
                throws IOException

Move the cursor to the next key-value pair. The entry returned by the previous entry() call will be invalid.

返回:

true if the cursor successfully moves. False when cursor is already at the end location and cannot be advanced.

抛出:

IOException

close

public void close()
           throws IOException

Close the scanner. Release all resources. The behavior of using the scanner after calling close is not defined. The entry returned by the previous entry() call will be invalid.

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

抛出:

IOException

atEnd

public boolean atEnd()

Is cursor at the end location?

返回:

true if the cursor is at the end location.

entry

public TFile.Reader.Scanner.Entry entry()
                                 throws IOException

Get an entry to access the key and value.

返回:

The Entry object to access the key and value.

抛出:

IOException

getRecordNum

public long getRecordNum()
                  throws IOException

Get the RecordNum corresponding to the entry pointed by the cursor.

返回:

The RecordNum corresponding to the entry pointed by the cursor.

抛出:

IOException