org.duracloud.services.amazonfixity

Class AmazonFixityPropertiesJobWorker

java.lang.Object

org.duracloud.services.amazonmapreduce.BaseAmazonMapReduceJobWorker

org.duracloud.services.amazonfixity.AmazonFixityPropertiesJobWorker

All Implemented Interfaces:

Runnable, AmazonMapReduceJobWorker

public class AmazonFixityPropertiesJobWorker
extends BaseAmazonMapReduceJobWorker

Nested Class Summary

Nested classes/interfaces inherited from interface org.duracloud.services.amazonmapreduce.AmazonMapReduceJobWorker

AmazonMapReduceJobWorker.JobStatus

Constructor Summary

Constructors

Constructor and Description
AmazonFixityPropertiesJobWorker(ContentStore contentStore, String workSpaceId, Map<String,String> taskParams, String serviceWorkDir)

Method Summary

Methods

Modifier and Type	Method and Description
protected Map<String,String>	getParamToResourceFileMap() This abstract method creates and returns a map of filenames that should be found in the service package, and their associated HadoopTypes.TASK_PARAM.name().

Methods inherited from class org.duracloud.services.amazonmapreduce.BaseAmazonMapReduceJobWorker

getError, getJobDetailsMap, getJobId, getJobStatus, run, shutdown

Methods inherited from class java.lang.Object

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

Constructor Detail

AmazonFixityPropertiesJobWorker

public AmazonFixityPropertiesJobWorker(ContentStore contentStore,
                               String workSpaceId,
                               Map<String,String> taskParams,
                               String serviceWorkDir)

Method Detail

getParamToResourceFileMap

protected Map<String,String> getParamToResourceFileMap()

Description copied from class: BaseAmazonMapReduceJobWorker

This abstract method creates and returns a map of filenames that should be found in the service package, and their associated HadoopTypes.TASK_PARAM.name().

Note: jars used by the hadoop framework must have the extension = .hjar so that the services-osgi-framework does not try to deploy the hadoop jar as a service. While copying the .hjar over to the storageprovider, the extension is then corrected to .jar .

Specified by:

getParamToResourceFileMap in class BaseAmazonMapReduceJobWorker

Returns:

map of resource filename => task param name