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

Interface RocksDBRestoreOperation

All Superinterfaces:

AutoCloseable, org.apache.flink.runtime.state.RestoreOperation<RocksDBRestoreResult>

All Known Implementing Classes:

RocksDBFullRestoreOperation, RocksDBHeapTimersFullRestoreOperation, RocksDBIncrementalRestoreOperation, RocksDBNoneRestoreOperation

public interface RocksDBRestoreOperation
extends org.apache.flink.runtime.state.RestoreOperation<RocksDBRestoreResult>, AutoCloseable

Interface for RocksDB restore.

Method Summary

Modifier and Type	Method	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 org.apache.flink.runtime.state.RestoreOperation<RocksDBRestoreResult>

Throws:

Exception