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

Modifier and Type	Method and 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

Methods inherited from interface java.io.Closeable

close

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