Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.runtime.memory |
Modifier and Type | Method and Description |
---|---|
static OpaqueMemoryResource<org.apache.flink.contrib.streaming.state.RocksDBSharedResources> |
RocksDBOperationUtils.allocateSharedCachesIfConfigured(RocksDBMemoryConfiguration memoryConfig,
MemoryManager memoryManager,
double memoryFraction,
org.slf4j.Logger logger) |
Constructor and Description |
---|
RocksDBResourceContainer(PredefinedOptions predefinedOptions,
RocksDBOptionsFactory optionsFactory,
OpaqueMemoryResource<org.apache.flink.contrib.streaming.state.RocksDBSharedResources> sharedResources) |
Modifier and Type | Method and Description |
---|---|
<T extends AutoCloseable> |
MemoryManager.getExternalSharedMemoryResource(String type,
LongFunctionWithException<T,Exception> initializer,
long numBytes)
Acquires a shared resource, identified by a type string.
|
<T extends AutoCloseable> |
MemoryManager.getSharedMemoryResourceForManagedMemory(String type,
LongFunctionWithException<T,Exception> initializer,
double fractionToInitializeWith)
Acquires a shared memory resource, identified by a type string.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.