edu.isi.pegasus.planner.transfer.mapper.impl
public class Hashed extends AbstractFileFactoryBasedMapper
org.griphyn.vdl.euryale.VirtualDecimalHashedFileFactory;
Modifier and Type | Field and Description |
---|---|
private static String |
DESCRIPTION
Short description.
|
private static int |
MAX_CACHE_ENTRIES
The maximum number of entries in the map, before the output site map
is cleared.
|
private int |
mNumberOfExistingLFNS |
private Map<String,Map<String,String>> |
mSiteLFNAddOnMap
A Map that tracks for each output site, the LFN to the Add on's
|
static String |
SHORT_NAME
The short name for the mapper
|
mFactory, mLogger, mOutputSite, mSiteStore, mStageoutDirectory
VERSION
Constructor and Description |
---|
Hashed() |
Modifier and Type | Method and Description |
---|---|
String |
createAndGetAddOn(String lfn,
String site,
boolean existing)
Returns the addOn part that is retrieved from the File Factory.
|
String |
description()
Returns a short description of the mapper.
|
String |
getShortName()
Returns the short name for the implementation class.
|
void |
initialize(PegasusBag bag,
ADag workflow)
Initializes the mappers.
|
org.griphyn.vdl.euryale.FileFactory |
instantiateFileFactory(PegasusBag bag,
ADag workflow)
Method that instantiates the FileFactory
|
private void |
resetLFNAddOnCache()
Resets the internal cache.
|
private void |
trackLFNAddOn(String site,
String lfn,
String addOn)
Tracks the lfn with addOn's on the various sites.
|
complainForStorageFileServer, constructURL, getErrorMessagePrefix, lookupStorageDirectory, map, map, mapAll
public static final String SHORT_NAME
private static final String DESCRIPTION
private Map<String,Map<String,String>> mSiteLFNAddOnMap
private static final int MAX_CACHE_ENTRIES
private int mNumberOfExistingLFNS
public void initialize(PegasusBag bag, ADag workflow) throws MapperException
initialize
in interface OutputMapper
initialize
in class AbstractFileFactoryBasedMapper
bag
- the bag of objects that is useful for initialization.workflow
- the workflow refined so far.MapperException
- if unable to construct URL for any reasonpublic org.griphyn.vdl.euryale.FileFactory instantiateFileFactory(PegasusBag bag, ADag workflow)
instantiateFileFactory
in class AbstractFileFactoryBasedMapper
bag
- the bag of objects that is useful for initialization.workflow
- the workflow refined so far.public String createAndGetAddOn(String lfn, String site, boolean existing)
createAndGetAddOn
in class AbstractFileFactoryBasedMapper
lfn
- the LFN to be usedsite
- the site at which the LFN residesexisting
- indicates whether to create a new location/placement for a file,
or rely on existing placement on the site.private void trackLFNAddOn(String site, String lfn, String addOn)
site
- lfn
- addOn
- public String getShortName()
getShortName
in class AbstractFileFactoryBasedMapper
public String description()
private void resetLFNAddOnCache()