com.asakusafw.runtime.util.cache

Class HadoopFileCacheRepository

java.lang.Object

com.asakusafw.runtime.util.cache.HadoopFileCacheRepository

All Implemented Interfaces:

FileCacheRepository

public class HadoopFileCacheRepository
extends Object
implements FileCacheRepository

Manages cache files on Hadoop file system.

Since:

0.7.0

Constructor Summary

Constructors

Constructor and Description
HadoopFileCacheRepository(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path repository, LockProvider<? super org.apache.hadoop.fs.Path> lockProvider, RetryStrategy retryStrategy) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.fs.Path	resolve(org.apache.hadoop.fs.Path file) Put a file into remote cache and returns the cached path.

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopFileCacheRepository

public HadoopFileCacheRepository(org.apache.hadoop.conf.Configuration configuration,
                                 org.apache.hadoop.fs.Path repository,
                                 LockProvider<? super org.apache.hadoop.fs.Path> lockProvider,
                                 RetryStrategy retryStrategy)

Creates a new instance.

Parameters:

configuration - the current configuration

repository - the cache root path (must be absolute)

lockProvider - the cache lock provider

retryStrategy - the retry strategy

Method Detail

resolve

public org.apache.hadoop.fs.Path resolve(org.apache.hadoop.fs.Path file)
                                  throws IOException,
                                         InterruptedException

Description copied from interface: FileCacheRepository

Put a file into remote cache and returns the cached path.

Specified by:

resolve in interface FileCacheRepository

Parameters:

file - the target file path

Returns:

the resolved path, or null path if this does not support the target file

Throws:

IOException - if failed to put the file into cache

InterruptedException - if interrupted while resolving cache file