RocksTransformingIteratorWrapper (Flink : State backends : RocksDB 1.20.2-cp1 API)

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

All Methods Instance Methods Concrete Methods
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