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

Class RocksDBStateDataTransferHelper

java.lang.Object

org.apache.flink.contrib.streaming.state.RocksDBStateDataTransferHelper

All Implemented Interfaces:

Closeable, AutoCloseable

public final class RocksDBStateDataTransferHelper
extends Object
implements Closeable

Data transfer helper for RocksDBKeyedStateBackend.

Method Summary

Modifier and Type	Method	Description
void	close()
static RocksDBStateDataTransferHelper	forThreadNum(int threadNum)
static RocksDBStateDataTransferHelper	forThreadNumIfSpecified(int threadNum, ExecutorService executorService)
ExecutorService	getExecutorService()

Methods inherited from class java.lang.Object

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

Method Detail

forThreadNum

public static RocksDBStateDataTransferHelper forThreadNum(int threadNum)

forThreadNumIfSpecified

public static RocksDBStateDataTransferHelper forThreadNumIfSpecified(int threadNum,
                                                                     ExecutorService executorService)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getExecutorService

public ExecutorService getExecutorService()