Package com.netflix.genie.common.internal.services.impl

Class JobDirectoryManifestCreatorServiceImpl

java.lang.Object

com.netflix.genie.common.internal.services.impl.JobDirectoryManifestCreatorServiceImpl

All Implemented Interfaces:

JobDirectoryManifestCreatorService

public class JobDirectoryManifestCreatorServiceImpl
extends Object
implements JobDirectoryManifestCreatorService

Implementation of JobDirectoryManifestCreatorService that caches manifests produced by the factory for a few seconds, thus avoiding re-calculating the same for subsequent requests (e.g. a user navigating a tree true the UI).

Since:

4.0.0

Constructor Summary

Constructors

Constructor	Description
JobDirectoryManifestCreatorServiceImpl(DirectoryManifest.Factory factory, com.github.benmanes.caffeine.cache.Cache<Path,DirectoryManifest> cache, boolean includeChecksum)	Constructor.

Method Summary

Modifier and Type	Method	Description
DirectoryManifest	getDirectoryManifest(Path jobDirectoryPath)	Produces a DirectoryManifest for the given job.
void	invalidateCachedDirectoryManifest(Path jobDirectoryPath)	If the implementation caches manifests to avoid excessive I/O, then demand the given cache entry be dropped, thus forcing a re-creation of manifest from scratch.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JobDirectoryManifestCreatorServiceImpl

public JobDirectoryManifestCreatorServiceImpl(DirectoryManifest.Factory factory,
 com.github.benmanes.caffeine.cache.Cache<Path,DirectoryManifest> cache,
 boolean includeChecksum)

Constructor.

Parameters:

factory - the directory manifest factory

cache - the loading cache to use

includeChecksum - whether to produce manifests that include checksums

Method Details

getDirectoryManifest

public DirectoryManifest getDirectoryManifest(Path jobDirectoryPath)
                                       throws IOException

Produces a DirectoryManifest for the given job.

Specified by:

getDirectoryManifest in interface JobDirectoryManifestCreatorService

Parameters:

jobDirectoryPath - the job directory

Returns:

a DirectoryManifest

Throws:

IOException - if the manifest cannot be created.

invalidateCachedDirectoryManifest

public void invalidateCachedDirectoryManifest(Path jobDirectoryPath)

If the implementation caches manifests to avoid excessive I/O, then demand the given cache entry be dropped, thus forcing a re-creation of manifest from scratch.

Specified by:

invalidateCachedDirectoryManifest in interface JobDirectoryManifestCreatorService

Parameters:

jobDirectoryPath - the job directory