net.sf.eos.hadoop
Class FullyDistributedCacheStrategy

java.lang.Object
  net.sf.eos.hadoop.FullyDistributedCacheStrategy

All Implemented Interfaces:

DistributedCacheStrategy

public class FullyDistributedCacheStrategy
extends Object
implements DistributedCacheStrategy

Supports the cache in a fully distributed environment.

Author:

Sascha Kohlmann

Field Summary

Fields inherited from interface net.sf.eos.hadoop.DistributedCacheStrategy

STRATEGY_IMPL_CONFIG_NAME

Constructor Summary

FullyDistributedCacheStrategy()

Method Summary

Path[]

distributedCachePathes(JobConf conf) Strategies implementing classes must implement this method.

Methods inherited from class java.lang.Object

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

Constructor Detail

FullyDistributedCacheStrategy

public FullyDistributedCacheStrategy()

Method Detail

distributedCachePathes

public Path[] distributedCachePathes(JobConf conf)
                              throws IOException

Description copied from interface: DistributedCacheStrategy

Strategies implementing classes must implement this method.

Specified by:

distributedCachePathes in interface DistributedCacheStrategy

Parameters:

conf - the environment configuration to get the cache

Returns:

pathes to the chache.

Throws:

IOException - if an error occurs