public class OutputMapperFactory extends Object
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_OUTPUT_MAPPER_IMPLEMENTATION
The default mapper implementation that is picked up.
|
static String |
DEFAULT_PACKAGE_NAME
The default package where the implementations reside, which this factory
loads.
|
static String |
HASHED_OUTPUT_MAPPER_IMPLEMENTATION
The Hashed mapper implementation to be used.
|
static String |
PROPERTY_KEY
The prefix for the property subset for connecting to the individual
catalogs.
|
Constructor and Description |
---|
OutputMapperFactory() |
Modifier and Type | Method and Description |
---|---|
static OutputMapper |
loadInstance(ADag dag,
PegasusBag bag)
Loads the implementing class corresponding to the value specified in the
properties.
|
static OutputMapper |
loadInstance(String className,
PegasusBag bag,
ADag dag)
Loads the implementing class corresponding to the class.
|
public static final String DEFAULT_PACKAGE_NAME
public static final String PROPERTY_KEY
public static final String DEFAULT_OUTPUT_MAPPER_IMPLEMENTATION
public static final String HASHED_OUTPUT_MAPPER_IMPLEMENTATION
public static OutputMapper loadInstance(ADag dag, PegasusBag bag) throws OutputMapperFactoryException
In addition it ends up loading the appropriate Transfer Implementation that is required by the mapper.
dag
- the workflow that is being refined.bag
- the bag of initialization objectsTransferOutputMapperException
- that nests any error that
might occur during the instantiation.OutputMapperFactoryException
DEFAULT_PACKAGE_NAME
public static OutputMapper loadInstance(String className, PegasusBag bag, ADag dag) throws OutputMapperFactoryException
className
- the name of the class that implements the mode.It can or
cannot be with the package name.bag
- the bag of initialization objectsdag
- the workflow that is being refined.OutputMapperFactoryException
- that nests any error that
might occur during the instantiation.DEFAULT_PACKAGE_NAME