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 java.lang.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 and Description
JobDirectoryManifestCreatorServiceImpl(DirectoryManifest.Factory factory, com.github.benmanes.caffeine.cache.Cache<java.nio.file.Path,DirectoryManifest> cache, boolean includeChecksum) Constructor.

Method Summary

Modifier and Type	Method and Description
DirectoryManifest	getDirectoryManifest(java.nio.file.Path jobDirectoryPath) Produces a DirectoryManifest for the given job.
void	invalidateCachedDirectoryManifest(java.nio.file.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 Detail

JobDirectoryManifestCreatorServiceImpl

public JobDirectoryManifestCreatorServiceImpl(DirectoryManifest.Factory factory,
                                              com.github.benmanes.caffeine.cache.Cache<java.nio.file.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 Detail

getDirectoryManifest

public DirectoryManifest getDirectoryManifest(java.nio.file.Path jobDirectoryPath)
                                       throws java.io.IOException

Produces a DirectoryManifest for the given job.

Specified by:

getDirectoryManifest in interface JobDirectoryManifestCreatorService

Parameters:

jobDirectoryPath - the job directory

Returns:

a DirectoryManifest

Throws:

java.io.IOException - if the manifest cannot be created.

invalidateCachedDirectoryManifest

public void invalidateCachedDirectoryManifest(java.nio.file.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