org.apache.flink.tests.util.cache

Class PersistingDownloadCache

java.lang.Object

org.apache.flink.tests.util.cache.PersistingDownloadCache

All Implemented Interfaces:

DownloadCache, ExternalResource, org.junit.rules.TestRule

public final class PersistingDownloadCache
extends Object

DownloadCache implementation that caches downloaded files in a configured directory. Cached files that are older than the configured time-to-live Period will be removed.

See Also:

PersistingDownloadCacheFactory, PersistingDownloadCacheFactory.TMP_DIR, PersistingDownloadCacheFactory.TIME_TO_LIVE

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
PersistingDownloadCache(Path path, java.time.Period ttl)

Method Summary

Modifier and Type	Method and Description
void	afterTestSuccess()
void	before()
Path	getOrDownload(String url, Path targetDir) Returns either a cached or newly downloaded version of the given file.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.tests.util.cache.DownloadCache

get

Methods inherited from interface org.apache.flink.util.ExternalResource

afterTestFailure, apply

Field Detail

log

protected final org.slf4j.Logger log

Constructor Detail

PersistingDownloadCache

public PersistingDownloadCache(Path path,
                               java.time.Period ttl)

Method Detail

before

public void before()
            throws IOException

Specified by:

before in interface ExternalResource

Throws:

IOException

afterTestSuccess

public void afterTestSuccess()

Specified by:

afterTestSuccess in interface ExternalResource

getOrDownload

public Path getOrDownload(String url,
                          Path targetDir)
                   throws IOException

Description copied from interface: DownloadCache

Returns either a cached or newly downloaded version of the given file. The returned file path is guaranteed to be located in the given target directory.

Specified by:

getOrDownload in interface DownloadCache

Parameters:

url - File/directory to download

targetDir - directory to place file in

Returns:

downloaded or cached file

Throws:

IOException - if any IO operation fails