Package org.apache.flink.runtime.blob
Interface JobPermanentBlobService
-
- All Superinterfaces:
AutoCloseable
,Closeable
,PermanentBlobService
- All Known Implementing Classes:
PermanentBlobCache
public interface JobPermanentBlobService extends PermanentBlobService
PermanentBlobService
extension that gives access to register and release job artifacts.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
registerJob(JobID jobId)
Register the given job.void
releaseJob(JobID jobId)
Release the given job.-
Methods inherited from interface org.apache.flink.runtime.blob.PermanentBlobService
getFile, readFile
-
-
-
-
Method Detail
-
registerJob
void registerJob(JobID jobId)
Register the given job.- Parameters:
jobId
- job id identifying the job to register
-
releaseJob
void releaseJob(JobID jobId)
Release the given job. This makes the blobs stored for this job up for cleanup.- Parameters:
jobId
- job id identifying the job to register
-
-