org.apache.flink.contrib.streaming.state

Class RocksDBStateDownloader

java.lang.Object

org.apache.flink.contrib.streaming.state.RocksDBStateDownloader

All Implemented Interfaces:

Closeable, AutoCloseable

public class RocksDBStateDownloader
extends Object

Help class for downloading RocksDB state files.

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutorService	executorService

Constructor Summary

Constructors

Constructor and Description
RocksDBStateDownloader(int restoringThreadNum, StateBackend.CustomInitializationMetrics customInitializationMetrics)

Method Summary

Modifier and Type	Method and Description
void	close()
void	transferAllStateDataToDirectory(Collection<StateHandleDownloadSpec> downloadRequests, CloseableRegistry closeableRegistry) Transfer all state data to the target directory, as specified in the download requests.

Methods inherited from class java.lang.Object

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

Field Detail

executorService

protected final ExecutorService executorService

Constructor Detail

RocksDBStateDownloader

public RocksDBStateDownloader(int restoringThreadNum,
                              StateBackend.CustomInitializationMetrics customInitializationMetrics)

Method Detail

transferAllStateDataToDirectory

public void transferAllStateDataToDirectory(Collection<StateHandleDownloadSpec> downloadRequests,
                                            CloseableRegistry closeableRegistry)
                                     throws Exception

Transfer all state data to the target directory, as specified in the download requests.

Parameters:

downloadRequests - the list of downloads.

Throws:

Exception - If anything about the download goes wrong.

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable