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 |
---|---|
int |
BlobKey.compareTo(BlobKey o) |
boolean |
BlobStore.delete(JobID jobId,
BlobKey blobKey)
Tries to delete a blob from storage.
|
boolean |
VoidBlobStore.delete(JobID jobId,
BlobKey blobKey) |
boolean |
FileSystemBlobStore.delete(JobID jobId,
BlobKey blobKey) |
boolean |
BlobView.get(JobID jobId,
BlobKey blobKey,
File localFile)
Copies a blob to a local file.
|
boolean |
VoidBlobStore.get(JobID jobId,
BlobKey blobKey,
File localFile) |
boolean |
FileSystemBlobStore.get(JobID jobId,
BlobKey blobKey,
File localFile) |
protected File |
TransientBlobCache.getFileInternal(JobID jobId,
BlobKey blobKey) |
protected File |
AbstractBlobCache.getFileInternal(JobID jobId,
BlobKey blobKey)
Returns local copy of the file for the BLOB with the given key.
|
File |
BlobServer.getStorageLocation(JobID jobId,
BlobKey key)
Returns a file handle to the file associated with the given blob key on the blob server.
|
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.
|
boolean |
BlobStore.put(File localFile,
JobID jobId,
BlobKey blobKey)
Copies the local file to the blob store.
|
boolean |
VoidBlobStore.put(File localFile,
JobID jobId,
BlobKey blobKey) |
boolean |
FileSystemBlobStore.put(File localFile,
JobID jobId,
BlobKey blobKey) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.