org.apache.flink.contrib.streaming.state

类 RocksIteratorWrapper

java.lang.Object

org.apache.flink.contrib.streaming.state.RocksIteratorWrapper

所有已实现的接口:

Closeable, AutoCloseable, org.rocksdb.RocksIteratorInterface

直接已知子类:

RocksTransformingIteratorWrapper

public class RocksIteratorWrapper
extends Object
implements org.rocksdb.RocksIteratorInterface, Closeable

This class was originally a wrapper around RocksIterator to check the iterator status for all the methods mentioned to require this check in the wiki documentation: seek, next, seekToFirst, seekToLast, seekForPrev, and prev. At that time, this was required because the iterator may pass the blocks or files it had difficulties in reading (because of IO errors, data corruptions or other issues) and continue with the next available keys. The status flag may not be OK, even if the iterator is valid.

However, after 3810 was merged, the behaviour had changed. If the iterator is valid, the status() is guaranteed to be OK; If the iterator is not valid, there are two possibilities: 1) We have reached the end of the data. And in this case, status() is OK; 2) There is an error. In this case, status() is not OK; More information can be found here.

构造器概要

构造器

构造器和说明
RocksIteratorWrapper(org.rocksdb.RocksIterator iterator)

方法概要

限定符和类型	方法和说明
void	close()
boolean	isValid()
byte[]	key()
void	next()
void	prev()
void	refresh()
void	seek(byte[] target)
void	seek(ByteBuffer target)
void	seekForPrev(byte[] target)
void	seekForPrev(ByteBuffer target)
void	seekToFirst()
void	seekToLast()
void	status()
byte[]	value()

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

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

构造器详细资料

RocksIteratorWrapper

public RocksIteratorWrapper(@Nonnull
                            org.rocksdb.RocksIterator iterator)

方法详细资料

isValid

public boolean isValid()

指定者:

isValid 在接口中 org.rocksdb.RocksIteratorInterface

seekToFirst

public void seekToFirst()

指定者:

seekToFirst 在接口中 org.rocksdb.RocksIteratorInterface

seekToLast

public void seekToLast()

指定者:

seekToLast 在接口中 org.rocksdb.RocksIteratorInterface

seek

public void seek(byte[] target)

指定者:

seek 在接口中 org.rocksdb.RocksIteratorInterface

seekForPrev

public void seekForPrev(byte[] target)

指定者:

seekForPrev 在接口中 org.rocksdb.RocksIteratorInterface

seek

public void seek(ByteBuffer target)

指定者:

seek 在接口中 org.rocksdb.RocksIteratorInterface

seekForPrev

public void seekForPrev(ByteBuffer target)

指定者:

seekForPrev 在接口中 org.rocksdb.RocksIteratorInterface

next

public void next()

指定者:

next 在接口中 org.rocksdb.RocksIteratorInterface

prev

public void prev()

指定者:

prev 在接口中 org.rocksdb.RocksIteratorInterface

status

public void status()

指定者:

status 在接口中 org.rocksdb.RocksIteratorInterface

refresh

public void refresh()
             throws org.rocksdb.RocksDBException

指定者:

refresh 在接口中 org.rocksdb.RocksIteratorInterface

抛出:

org.rocksdb.RocksDBException

key

public byte[] key()

value

public byte[] value()

close

public void close()

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable