edu.isi.pegasus.planner.client
public class PasoaProvenanceClient extends Object
Modifier and Type | Field and Description |
---|---|
List |
children |
org.pasoa.storeclient.ClientLib |
clientLib |
static String |
CONDOR |
Element |
daxelement |
Element |
docelement |
static String |
documentationStyle |
long |
filecount |
Map |
input |
String |
jobname |
Map |
output |
List |
parents |
URL |
provenanceStore |
String |
transformation |
static String |
URL
change this to connect to the preserv server
|
String |
wf_label |
String |
wf_planned_time |
static String |
XMLHEADER |
Constructor and Description |
---|
PasoaProvenanceClient() |
PasoaProvenanceClient(String url) |
Modifier and Type | Method and Description |
---|---|
private org.pasoa.pstructure.ActorStatePAssertion |
createActorStatePAssertion(long count) |
private org.pasoa.pstructure.InteractionPAssertion |
createJobCompletionInteractionPAssertion() |
private org.pasoa.pstructure.InteractionPAssertion |
createJobInvocationInteractionPAssertion() |
private org.pasoa.pstructure.RelationshipPAssertion |
createJobRelationshipPAssertion(org.pasoa.pstructure.InteractionKey invocationik,
String filename,
long index) |
private org.pasoa.pstructure.RelationshipPAssertion |
createJobToTransferRelationshipPAssertion(String filename,
String parentjob,
int index) |
private Element |
createLFNDataAccessor(String value) |
private org.pasoa.pstructure.InteractionPAssertion |
createMergedJobInvocationInteractionPAssertion() |
private org.pasoa.pstructure.InteractionPAssertion |
createRegisterInvocationInteractionPAssertion() |
private org.pasoa.pstructure.RelationshipPAssertion |
createRegisterToTransferRelationshipPAssertion(String parentjob,
long index) |
private org.pasoa.pstructure.InteractionPAssertion |
createTransferCompletionInteractionPAssertion() |
private Element |
createTransferDataAccessor(long index) |
private org.pasoa.pstructure.InteractionPAssertion |
createTransferInvocationInteractionPAssertion() |
private org.pasoa.pstructure.RelationshipPAssertion |
createTransferRelationshipPAssertion(org.pasoa.pstructure.InteractionKey invocationik,
long index) |
List |
extractToMemory(File input) |
void |
jobCompletionInteraction(org.pasoa.pstructure.InteractionKey invocationinteractionkey) |
org.pasoa.pstructure.InteractionKey |
jobInvocationInteraction() |
static void |
main(String[] args) |
private void |
parseDag(String file) |
private void |
parseDaxFile(String file,
List jobs) |
private void |
parseFiles(List jobs) |
private void |
parseInput() |
private void |
parseKickstartRecord(String file) |
void |
registerCompletionInteraction(org.pasoa.pstructure.InteractionKey invocationinteractionkey) |
org.pasoa.pstructure.InteractionKey |
registerInvocationInteraction() |
void |
transferCompletionInteraction(org.pasoa.pstructure.InteractionKey invocationinteractionkey) |
org.pasoa.pstructure.InteractionKey |
transferInvocationInteraction() |
public static String URL
public static String XMLHEADER
public static String CONDOR
public long filecount
public static String documentationStyle
public org.pasoa.storeclient.ClientLib clientLib
public URL provenanceStore
public String jobname
public String wf_label
public String wf_planned_time
public String transformation
public Element docelement
public Element daxelement
public List parents
public List children
public Map input
public Map output
public PasoaProvenanceClient(String url)
public PasoaProvenanceClient()
private void parseKickstartRecord(String file) throws Exception
Exception
public org.pasoa.pstructure.InteractionKey jobInvocationInteraction() throws Exception
Exception
public void jobCompletionInteraction(org.pasoa.pstructure.InteractionKey invocationinteractionkey) throws Exception
Exception
public org.pasoa.pstructure.InteractionKey transferInvocationInteraction() throws Exception
Exception
public void transferCompletionInteraction(org.pasoa.pstructure.InteractionKey invocationinteractionkey) throws Exception
Exception
private org.pasoa.pstructure.InteractionPAssertion createTransferInvocationInteractionPAssertion() throws Exception
Exception
private org.pasoa.pstructure.InteractionPAssertion createTransferCompletionInteractionPAssertion() throws Exception
Exception
private org.pasoa.pstructure.ActorStatePAssertion createActorStatePAssertion(long count) throws Exception
Exception
private org.pasoa.pstructure.RelationshipPAssertion createTransferRelationshipPAssertion(org.pasoa.pstructure.InteractionKey invocationik, long index) throws Exception
Exception
private org.pasoa.pstructure.InteractionPAssertion createMergedJobInvocationInteractionPAssertion() throws Exception
Exception
private org.pasoa.pstructure.InteractionPAssertion createJobInvocationInteractionPAssertion() throws Exception
Exception
private org.pasoa.pstructure.InteractionPAssertion createJobCompletionInteractionPAssertion() throws Exception
Exception
private org.pasoa.pstructure.RelationshipPAssertion createJobRelationshipPAssertion(org.pasoa.pstructure.InteractionKey invocationik, String filename, long index) throws Exception
Exception
private org.pasoa.pstructure.RelationshipPAssertion createJobToTransferRelationshipPAssertion(String filename, String parentjob, int index) throws Exception
Exception
private Element createTransferDataAccessor(long index)
private org.pasoa.pstructure.InteractionPAssertion createRegisterInvocationInteractionPAssertion() throws Exception
Exception
public org.pasoa.pstructure.InteractionKey registerInvocationInteraction() throws Exception
Exception
public void registerCompletionInteraction(org.pasoa.pstructure.InteractionKey invocationinteractionkey) throws Exception
Exception