Package org.apache.flink.contrib.streaming.state.iterator

Class RocksTransformingIteratorWrapper

java.lang.Object

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

org.apache.flink.contrib.streaming.state.iterator.RocksTransformingIteratorWrapper

All Implemented Interfaces:

Closeable, AutoCloseable, org.rocksdb.RocksIteratorInterface

public class RocksTransformingIteratorWrapper
extends RocksIteratorWrapper

Wrapper around RocksIterator that applies a given StateSnapshotTransformer to the elements during the iteration.

Constructor Summary

Constructors

Constructor	Description
RocksTransformingIteratorWrapper(org.rocksdb.RocksIterator iterator, org.apache.flink.runtime.state.StateSnapshotTransformer<byte[]> stateSnapshotTransformer)

Method Summary

Modifier and Type	Method	Description
void	next()
void	prev()
void	seekToFirst()
void	seekToLast()
byte[]	value()

Methods inherited from class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper

close, isValid, key, refresh, seek, seek, seekForPrev, seekForPrev, status

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksTransformingIteratorWrapper

public RocksTransformingIteratorWrapper(@Nonnull
                                        org.rocksdb.RocksIterator iterator,
                                        @Nonnull
                                        org.apache.flink.runtime.state.StateSnapshotTransformer<byte[]> stateSnapshotTransformer)

Method Detail

seekToFirst

public void seekToFirst()

Specified by:

seekToFirst in interface org.rocksdb.RocksIteratorInterface

Overrides:

seekToFirst in class RocksIteratorWrapper

seekToLast

public void seekToLast()

Specified by:

seekToLast in interface org.rocksdb.RocksIteratorInterface

Overrides:

seekToLast in class RocksIteratorWrapper

next

public void next()

Specified by:

next in interface org.rocksdb.RocksIteratorInterface

Overrides:

next in class RocksIteratorWrapper

prev

public void prev()

Specified by:

prev in interface org.rocksdb.RocksIteratorInterface

Overrides:

prev in class RocksIteratorWrapper

value

public byte[] value()

Overrides:

value in class RocksIteratorWrapper