Package | Description |
---|---|
org.apache.flink.runtime.blob | |
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.execution.librarycache | |
org.apache.flink.runtime.filecache |
Modifier and Type | Class and Description |
---|---|
class |
BlobServer
This class implements the BLOB server.
|
class |
PermanentBlobCache
Provides a cache for permanent BLOB files including a per-job ref-counting and a staged cleanup.
|
Modifier and Type | Method and Description |
---|---|
PermanentBlobService |
BlobServer.getPermanentBlobService() |
PermanentBlobService |
BlobService.getPermanentBlobService()
Returns a BLOB service for accessing permanent BLOBs.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskDeploymentDescriptor.loadBigData(PermanentBlobService blobService)
Loads externalized data from the BLOB store back to the object.
|
Constructor and Description |
---|
BlobLibraryCacheManager(PermanentBlobService blobService,
FlinkUserCodeClassLoaders.ResolveOrder classLoaderResolveOrder,
String[] alwaysParentFirstPatterns) |
BlobLibraryCacheManager(PermanentBlobService blobService,
FlinkUserCodeClassLoaders.ResolveOrder classLoaderResolveOrder,
String[] alwaysParentFirstPatterns,
FatalErrorHandler fatalErrorHandler) |
Constructor and Description |
---|
FileCache(String[] tempDirectories,
PermanentBlobService blobService) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.