org.duracloud.services.bulkimageconversion

Class BulkImageConversionService

java.lang.Object

org.duracloud.services.BaseService

org.duracloud.services.amazonmapreduce.BaseAmazonMapReduceService

org.duracloud.services.bulkimageconversion.BulkImageConversionService

All Implemented Interfaces:

ComputeService, org.osgi.service.cm.ManagedService

public class BulkImageConversionService
extends BaseAmazonMapReduceService
implements ComputeService, org.osgi.service.cm.ManagedService

Service which converts image files from one format to another in a bulk fashion by utilizing hadoop.

Author:

Bill Branan Date: Aug 17, 2010

Nested Class Summary

Nested classes/interfaces inherited from interface org.duracloud.services.ComputeService

ComputeService.ServiceStatus

Field Summary

Fields inherited from class org.duracloud.services.amazonmapreduce.BaseAmazonMapReduceService

DEFAULT_INSTANCE_TYPE, DEFAULT_NUM_INSTANCES, DEFAULT_NUM_MAPPERS, OPTIMIZE_COST, OPTIMIZE_MODE_STANDARD, OPTIMIZE_SPEED

Fields inherited from interface org.duracloud.services.ComputeService

DELIM, ERROR_KEY, ERROR_REPORT_KEY, FAILURE_COUNT_KEY, ITEMS_PROCESS_COUNT, PASS_COUNT_KEY, REPORT_KEY, STARTTIME_KEY, STATUS_KEY, STOPTIME_KEY, SVC_LAUNCHING_USER, SYSTEM_PREFIX

Constructor Summary

Constructors

Constructor and Description
BulkImageConversionService()

Method Summary

Methods

Modifier and Type	Method and Description
protected Map<String,String>	collectTaskParams()
String	getColorSpace()
protected String	getJobType()
protected AmazonMapReduceJobWorker	getJobWorker()
String	getNamePrefix()
String	getNameSuffix()
protected String	getNumMappers(String instanceType)
String	getOutputSpaceId()
protected AmazonMapReduceJobWorker	getPostJobWorker()
String	getToFormat()
void	setColorSpace(String colorSpace)
void	setNamePrefix(String namePrefix)
void	setNameSuffix(String nameSuffix)
void	setOutputSpaceId(String outputSpaceId)
void	setToFormat(String toFormat)
void	stop()

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

createDestSpace, doneWorking, getContentStore, getCostInstanceType, getCostNumInstances, getDestSpaceId, getDuraStoreContext, getDuraStoreHost, getDuraStorePort, getInstancesType, getInstanceType, getMappersPerInstance, getNumInstances, getNumOfInstances, getOptimizeMode, getOptimizeType, getPassword, getServiceProps, getSourceSpaceId, getSpeedInstanceType, getSpeedNumInstances, getUsername, getWorkSpaceId, setContentStore, setCostInstanceType, setCostNumInstances, setDestSpaceId, setDuraStoreContext, setDuraStoreHost, setDuraStorePort, setInstanceType, setMappersPerInstance, setNumInstances, setOptimizeMode, setOptimizeType, setPassword, setSourceSpaceId, setSpeedInstanceType, setSpeedNumInstances, setUsername, setWorkSpaceId, start, updated

Methods inherited from class org.duracloud.services.BaseService

addErrorReport, describe, getError, getErrorReportId, getServiceId, getServiceStatus, getServiceWorkDir, getSvcLaunchingUser, setError, setErrorReportId, setErrorReportId, setReportId, setReportId, setServiceId, setServiceStatus, setServiceWorkDir, setSvcLaunchingUser

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.duracloud.services.ComputeService

describe, getServiceId, getServiceProps, getServiceStatus, getServiceWorkDir, setServiceWorkDir, start

Methods inherited from interface org.osgi.service.cm.ManagedService

updated

Constructor Detail

BulkImageConversionService

public BulkImageConversionService()

Method Detail

getJobWorker

protected AmazonMapReduceJobWorker getJobWorker()

Specified by:

getJobWorker in class BaseAmazonMapReduceService

getPostJobWorker

protected AmazonMapReduceJobWorker getPostJobWorker()

Specified by:

getPostJobWorker in class BaseAmazonMapReduceService

getJobType

protected String getJobType()

Specified by:

getJobType in class BaseAmazonMapReduceService

getNumMappers

protected String getNumMappers(String instanceType)

Specified by:

getNumMappers in class BaseAmazonMapReduceService

collectTaskParams

protected Map<String,String> collectTaskParams()

Overrides:

collectTaskParams in class BaseAmazonMapReduceService

stop

public void stop()
          throws Exception

Specified by:

stop in interface ComputeService

Overrides:

stop in class BaseAmazonMapReduceService

Throws:

Exception

getOutputSpaceId

public String getOutputSpaceId()

setOutputSpaceId

public void setOutputSpaceId(String outputSpaceId)

getToFormat

public String getToFormat()

setToFormat

public void setToFormat(String toFormat)

getColorSpace

public String getColorSpace()

setColorSpace

public void setColorSpace(String colorSpace)

getNamePrefix

public String getNamePrefix()

setNamePrefix

public void setNamePrefix(String namePrefix)

getNameSuffix

public String getNameSuffix()

setNameSuffix

public void setNameSuffix(String nameSuffix)