public class PGETaskInstance extends Object implements WorkflowTaskInstance
Modifier and Type | Field and Description |
---|---|
protected Logger |
logger |
protected PgeConfig |
pgeConfig |
protected PgeMetadata |
pgeMetadata |
protected XmlRpcWorkflowManagerClient |
wm |
protected String |
workflowInstId |
Modifier | Constructor and Description |
---|---|
protected |
PGETaskInstance() |
protected Logger logger
protected XmlRpcWorkflowManagerClient wm
protected String workflowInstId
protected PgeMetadata pgeMetadata
protected PgeConfig pgeConfig
public void run(Metadata metadata, WorkflowTaskConfiguration config) throws WorkflowTaskInstanceException
WorkflowTaskInstance
Runs the Task with the specified metadata context.
run
in interface WorkflowTaskInstance
metadata
- The TaskContext of metadata that is shared between the tasks.config
- The static configuration metadata for this task.WorkflowTaskInstanceException
protected PgeMetadata createPgeMetadata(Metadata dynMetadata, WorkflowTaskConfiguration config) throws Exception
Exception
protected ConfigFilePropertyAdder loadPropertyAdder(String propertyAdderClasspath) throws Exception
Exception
protected void runPropertyAdder(ConfigFilePropertyAdder propAdder) throws Exception
Exception
protected XmlRpcWorkflowManagerClient createWorkflowManagerClient() throws Exception
Exception
protected void createOuputDirsIfRequested() throws Exception
Exception
protected FileStager getFileStager() throws Exception
Exception
protected void createDynamicConfigFiles() throws Exception
Exception
protected void createDynamicConfigFile(DynamicConfigFile dynamicConfigFile) throws Exception
Exception
protected ScriptFile buildPgeRunScript()
protected File getScriptPath()
protected String getPgeScriptName()
protected boolean wasPgeSuccessful(int returnCode)
protected void processOutput() throws FileNotFoundException, IOException
FileNotFoundException
IOException
protected File renameFile(File file, PathUtilsNamingConvention renamingConv) throws Exception
Exception
protected Metadata getMetadataForFile(File sciPgeCreatedDataFile, PcsMetFileWriter writer, Object[] args) throws Exception
Exception
protected void writeFromMetadata(Metadata metadata, String toMetFilePath) throws FileNotFoundException, IOException
FileNotFoundException
IOException
protected ProductCrawler createProductCrawler() throws Exception
Exception
protected void runIngestCrawler(ProductCrawler crawler) throws Exception
Exception
protected void verifyIngests(ProductCrawler crawler) throws Exception
Exception
Copyright © 1999-2014 Apache OODT. All Rights Reserved.