org.apache.flink.contrib.streaming.state.restore

Interface RocksDBRestoreOperation

All Superinterfaces:

AutoCloseable, RestoreOperation<RocksDBRestoreResult>

All Known Implementing Classes:

RocksDBFullRestoreOperation, RocksDBHeapTimersFullRestoreOperation, RocksDBIncrementalRestoreOperation, RocksDBNoneRestoreOperation

@Internal
public interface RocksDBRestoreOperation
extends RestoreOperation<RocksDBRestoreResult>, AutoCloseable

Interface for RocksDB restore.

Method Summary

Modifier and Type	Method and Description
RocksDBRestoreResult	restore() Restores state that was previously snapshot-ed from the provided state handles.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

restore

RocksDBRestoreResult restore()
                      throws Exception

Restores state that was previously snapshot-ed from the provided state handles.

Specified by:

restore in interface RestoreOperation<RocksDBRestoreResult>

Throws:

Exception