Uses of Class
org.apache.flink.runtime.blob.TransientBlobKey

Packages that use TransientBlobKey

Package	Description
org.apache.flink.runtime.blob
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.rest.handler.taskmanager
org.apache.flink.runtime.taskexecutor

Uses of TransientBlobKey in org.apache.flink.runtime.blob

Methods in org.apache.flink.runtime.blob that return TransientBlobKey

Modifier and Type	Method and Description
TransientBlobKey	BlobServer.putTransient(byte[] value)
TransientBlobKey	TransientBlobService.putTransient(byte[] value) Uploads the (job-unrelated) data of the given byte array to the BLOB server.
TransientBlobKey	TransientBlobCache.putTransient(byte[] value)
TransientBlobKey	BlobServer.putTransient(InputStream inputStream)
TransientBlobKey	TransientBlobService.putTransient(InputStream inputStream) Uploads the (job-unrelated) data from the given input stream to the BLOB server.
TransientBlobKey	TransientBlobCache.putTransient(InputStream inputStream)
TransientBlobKey	BlobServer.putTransient(JobID jobId, byte[] value)
TransientBlobKey	TransientBlobService.putTransient(JobID jobId, byte[] value) Uploads the data of the given byte array for the given job to the BLOB server.
TransientBlobKey	TransientBlobCache.putTransient(JobID jobId, byte[] value)
TransientBlobKey	BlobServer.putTransient(JobID jobId, InputStream inputStream)
TransientBlobKey	TransientBlobService.putTransient(JobID jobId, InputStream inputStream) Uploads the data from the given input stream for the given job to the BLOB server.
TransientBlobKey	TransientBlobCache.putTransient(JobID jobId, InputStream inputStream)

Methods in org.apache.flink.runtime.blob with parameters of type TransientBlobKey

Modifier and Type	Method and Description
boolean	BlobServer.deleteFromCache(JobID jobId, TransientBlobKey key) Deletes the file associated with the blob key in the local storage of the blob server.
boolean	TransientBlobService.deleteFromCache(JobID jobId, TransientBlobKey key) Deletes the file associated with the provided job ID and blob key from the local cache.
boolean	TransientBlobCache.deleteFromCache(JobID jobId, TransientBlobKey key)
boolean	BlobServer.deleteFromCache(TransientBlobKey key) Deletes the (job-unrelated) file associated with the blob key in the local storage of the blob server.
boolean	TransientBlobService.deleteFromCache(TransientBlobKey key) Deletes the (job-unrelated) file associated with the provided blob key from the local cache.
boolean	TransientBlobCache.deleteFromCache(TransientBlobKey key)
File	BlobServer.getFile(JobID jobId, TransientBlobKey key) Retrieves the local path of a file associated with a job and a blob key.
File	TransientBlobService.getFile(JobID jobId, TransientBlobKey key) Returns the path to a local copy of the file associated with the provided job ID and blob key.
File	TransientBlobCache.getFile(JobID jobId, TransientBlobKey key)
File	BlobServer.getFile(TransientBlobKey key) Retrieves the local path of a (job-unrelated) file associated with a job and a blob key.
File	TransientBlobService.getFile(TransientBlobKey key) Returns the path to a local copy of the (job-unrelated) file associated with the provided blob key.
File	TransientBlobCache.getFile(TransientBlobKey key)

Uses of TransientBlobKey in org.apache.flink.runtime.resourcemanager

Methods in org.apache.flink.runtime.resourcemanager that return types with arguments of type TransientBlobKey

Modifier and Type	Method and Description
CompletableFuture<TransientBlobKey>	ResourceManagerGateway.requestTaskManagerFileUploadByName(ResourceID taskManagerId, String fileName, Time timeout) Request the file upload from the given TaskExecutor to the cluster's BlobServer.
CompletableFuture<TransientBlobKey>	ResourceManager.requestTaskManagerFileUploadByName(ResourceID taskManagerId, String fileName, Time timeout)
CompletableFuture<TransientBlobKey>	ResourceManagerGateway.requestTaskManagerFileUploadByType(ResourceID taskManagerId, FileType fileType, Time timeout) Request the file upload from the given TaskExecutor to the cluster's BlobServer.
CompletableFuture<TransientBlobKey>	ResourceManager.requestTaskManagerFileUploadByType(ResourceID taskManagerId, FileType fileType, Time timeout)

Uses of TransientBlobKey in org.apache.flink.runtime.rest.handler.taskmanager

Methods in org.apache.flink.runtime.rest.handler.taskmanager that return types with arguments of type TransientBlobKey

Modifier and Type	Method and Description
protected abstract CompletableFuture<TransientBlobKey>	AbstractTaskManagerFileHandler.requestFileUpload(ResourceManagerGateway resourceManagerGateway, Tuple2<ResourceID,String> taskManagerIdAndFileName)
protected CompletableFuture<TransientBlobKey>	TaskManagerLogFileHandler.requestFileUpload(ResourceManagerGateway resourceManagerGateway, Tuple2<ResourceID,String> taskManagerIdAndFileName)
protected CompletableFuture<TransientBlobKey>	TaskManagerStdoutFileHandler.requestFileUpload(ResourceManagerGateway resourceManagerGateway, Tuple2<ResourceID,String> taskManagerIdAndFileName)
protected CompletableFuture<TransientBlobKey>	TaskManagerCustomLogHandler.requestFileUpload(ResourceManagerGateway resourceManagerGateway, Tuple2<ResourceID,String> taskManagerIdAndFileName)

Uses of TransientBlobKey in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor that return types with arguments of type TransientBlobKey

Modifier and Type	Method and Description
CompletableFuture<TransientBlobKey>	TaskExecutor.requestFileUploadByName(String fileName, Time timeout)
CompletableFuture<TransientBlobKey>	TaskExecutorGateway.requestFileUploadByName(String fileName, Time timeout) Requests the file upload of the specified name to the cluster's BlobServer.
CompletableFuture<TransientBlobKey>	TaskExecutor.requestFileUploadByType(FileType fileType, Time timeout)
CompletableFuture<TransientBlobKey>	TaskExecutorGateway.requestFileUploadByType(FileType fileType, Time timeout) Requests the file upload of the specified type to the cluster's BlobServer.