public class Hashed extends AbstractFileFactoryBasedMapper
org.griphyn.vdl.euryale.VirtualDecimalHashedFileFactory;
Modifier and Type | Field and Description |
---|---|
private static java.lang.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 java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> |
mSiteLFNAddOnMap
A Map that tracks for each output site, the LFN to the Add on's
|
static java.lang.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 |
---|---|
java.lang.String |
createAndGetAddOn(java.lang.String lfn,
java.lang.String site,
boolean existing)
Returns the addOn part that is retrieved from the File Factory.
|
java.lang.String |
description()
Returns a short description of the mapper.
|
java.lang.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(java.lang.String site,
java.lang.String lfn,
java.lang.String addOn)
Tracks the lfn with addOn's on the various sites.
|
complainForStorageFileServer, constructURL, getErrorMessagePrefix, lookupStorageDirectory, map, map, mapAll
public static final java.lang.String SHORT_NAME
private static final java.lang.String DESCRIPTION
private java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.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 java.lang.String createAndGetAddOn(java.lang.String lfn, java.lang.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(java.lang.String site, java.lang.String lfn, java.lang.String addOn)
site
- lfn
- addOn
- public java.lang.String getShortName()
getShortName
in class AbstractFileFactoryBasedMapper
public java.lang.String description()
private void resetLFNAddOnCache()