Package | Description |
---|---|
org.apache.flink.runtime.blob |
Modifier and Type | Class and Description |
---|---|
class |
PermanentBlobKey
BLOB key referencing permanent BLOB files.
|
class |
TransientBlobKey
BLOB key referencing transient BLOB files.
|
Modifier and Type | Method and Description |
---|---|
List<Tuple2<JobID,BlobKey>> |
BlobCacheSizeTracker.checkLimit(long size)
Check the size limit and return the BLOBs to delete.
|
Modifier and Type | Method and Description |
---|---|
int |
BlobKey.compareTo(BlobKey o) |
boolean |
VoidBlobStore.delete(JobID jobId,
BlobKey blobKey) |
boolean |
FileSystemBlobStore.delete(JobID jobId,
BlobKey blobKey) |
boolean |
BlobStore.delete(JobID jobId,
BlobKey blobKey)
Tries to delete a blob from storage.
|
boolean |
VoidBlobStore.get(JobID jobId,
BlobKey blobKey,
File localFile) |
boolean |
FileSystemBlobStore.get(JobID jobId,
BlobKey blobKey,
File localFile) |
boolean |
BlobView.get(JobID jobId,
BlobKey blobKey,
File localFile)
Copies a blob to a local file.
|
protected File |
AbstractBlobCache.getFileInternal(JobID jobId,
BlobKey blobKey)
Returns local copy of the file for the BLOB with the given key.
|
protected File |
TransientBlobCache.getFileInternal(JobID jobId,
BlobKey blobKey) |
File |
PermanentBlobCache.getStorageLocation(JobID jobId,
BlobKey key)
Returns a file handle to the file associated with the given blob key on the blob server.
|
File |
TransientBlobCache.getStorageLocation(JobID jobId,
BlobKey key)
Returns a file handle to the file associated with the given blob key on the blob server.
|
File |
BlobServer.getStorageLocation(JobID jobId,
BlobKey key)
Returns a file handle to the file associated with the given blob key on the blob server.
|
boolean |
VoidBlobStore.put(File localFile,
JobID jobId,
BlobKey blobKey) |
boolean |
FileSystemBlobStore.put(File localFile,
JobID jobId,
BlobKey blobKey) |
boolean |
BlobStore.put(File localFile,
JobID jobId,
BlobKey blobKey)
Copies the local file to the blob store.
|
void |
BlobCacheSizeTracker.track(JobID jobId,
BlobKey blobKey,
long size)
Register the BLOB to the tracker.
|
void |
BlobCacheSizeTracker.update(JobID jobId,
BlobKey blobKey)
Update the least used index for the BLOBs so that the tracker can easily find out the least
recently used BLOBs.
|
Modifier and Type | Method and Description |
---|---|
void |
BlobCacheSizeTracker.untrack(Tuple2<JobID,BlobKey> key)
Remove the BLOB from the tracker.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.