org.processmining.hadoop.models

Class HadoopAnnotatedDGraph

java.lang.Object

org.processmining.hadoop.models.HadoopDGraph

org.processmining.hadoop.models.HadoopAnnotatedDGraph

public class HadoopAnnotatedDGraph
extends HadoopDGraph

Model for the annotated dependency graph. This class extends the dependency graph (DGraph) implementation with multisets for the split/joins because of the necessity of counting the frequencies. TODO: It could be useful to save the long distance dependencies separately

Author:

shernandez

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.HashMap<java.lang.String,Multiset<java.util.Set<java.lang.String>>>	join_multisets
protected java.util.HashMap<java.lang.String,Multiset<java.util.Set<java.lang.String>>>	split_multisets

Fields inherited from class org.processmining.hadoop.models.HadoopDGraph

activities, causesMap, entries, successorsMap

Constructor Summary

Constructors

Constructor and Description
HadoopAnnotatedDGraph()
HadoopAnnotatedDGraph(HadoopDGraph dg)

Method Summary

Modifier and Type	Method and Description
java.lang.String	activityAsString(java.lang.String act)
void	add(HadoopAnnotatedDGraph a_dgraph) Add data from the parameter graph to the actual graph
void	countJoinSet(java.lang.String activity, java.util.Set<java.lang.String> set) Count the appearance of a new set as a join of the activity
void	countJoinSet(java.lang.String activity, java.util.Set<java.lang.String> set, long count) Count the appearance of a new set as a join of the activity
void	countSplitSet(java.lang.String activity, java.util.Set<java.lang.String> set) Count the appearance of a new set as a split of the activity
void	countSplitSet(java.lang.String activity, java.util.Set<java.lang.String> set, long count) Count the appearance of a new set as a split of the activity
long	getActivityCount(java.lang.String activity) Return the total number of appearances of the activity in the log
long	getCount(java.lang.String predecessor, java.lang.String successor) Return the number of times the predecessor is followed by the successor
java.util.Set<java.lang.String>	getEndActivities() A set with the end activities
long	getEndCount(java.lang.String activity) Return the number of times the activity is the end activity
java.util.Set<java.lang.String>	getIntermediateActivities() A set with the intermediate activities
long	getJoinCount(java.lang.String activity, java.util.Set<java.lang.String> set) Return the number of the occurrence of the set in the join multiset
Multiset<java.util.Set<java.lang.String>>	getJoins(java.lang.String activity) Return the joins of the activity
long	getSplitCount(java.lang.String activity, java.util.Set<java.lang.String> set) Return the number of the occurrence of the set in the split multiset
Multiset<java.util.Set<java.lang.String>>	getSplits(java.lang.String activity) Return the splits of the activity
java.util.Set<java.lang.String>	getStartActivities() A set with the start activities
long	getStartCount(java.lang.String activity) Return the number of times the activity is the start activity
protected java.util.Set<java.lang.String>	processSetString(java.lang.String string_set) Transform the set represented as a string to a Set object
boolean	read(java.lang.String filename) Read a dependency graph from an input file
java.lang.String	toString()

Methods inherited from class org.processmining.hadoop.models.HadoopDGraph

add, add, contains, getActivities, getCauses, getEntries, getFollowers, remove, write, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

join_multisets

protected java.util.HashMap<java.lang.String,Multiset<java.util.Set<java.lang.String>>> join_multisets

split_multisets

protected java.util.HashMap<java.lang.String,Multiset<java.util.Set<java.lang.String>>> split_multisets

Constructor Detail

HadoopAnnotatedDGraph

public HadoopAnnotatedDGraph()

HadoopAnnotatedDGraph

public HadoopAnnotatedDGraph(HadoopDGraph dg)

Method Detail

getSplits

public Multiset<java.util.Set<java.lang.String>> getSplits(java.lang.String activity)

Return the splits of the activity

Parameters:

activity - Activity

Returns:

The splits of the activity

getJoins

public Multiset<java.util.Set<java.lang.String>> getJoins(java.lang.String activity)

Return the joins of the activity

Parameters:

activity - Activity

Returns:

The joins of the activity

countJoinSet

public void countJoinSet(java.lang.String activity,
                         java.util.Set<java.lang.String> set)

Count the appearance of a new set as a join of the activity

Parameters:

activity - Activity

set - Successor set

countSplitSet

public void countSplitSet(java.lang.String activity,
                          java.util.Set<java.lang.String> set)

Count the appearance of a new set as a split of the activity

Parameters:

activity - Activity

set - Causes set

countJoinSet

public void countJoinSet(java.lang.String activity,
                         java.util.Set<java.lang.String> set,
                         long count)

Count the appearance of a new set as a join of the activity

Parameters:

activity - Activity

set - Successor set

count - Count

countSplitSet

public void countSplitSet(java.lang.String activity,
                          java.util.Set<java.lang.String> set,
                          long count)

Count the appearance of a new set as a split of the activity

Parameters:

activity - Activity

set - Causes set

count - Count

getJoinCount

public long getJoinCount(java.lang.String activity,
                         java.util.Set<java.lang.String> set)

Return the number of the occurrence of the set in the join multiset

Parameters:

activity - Activity

set - Set

Returns:

The number of the occurrence of the set in the join multiset

getCount

public long getCount(java.lang.String predecessor,
                     java.lang.String successor)

Return the number of times the predecessor is followed by the successor

Parameters:

predecessor - Predecessor activity

successor - Successor activity

Returns:

The number of times the predecessor is followed by the successor

getSplitCount

public long getSplitCount(java.lang.String activity,
                          java.util.Set<java.lang.String> set)

Return the number of the occurrence of the set in the split multiset

Parameters:

activity - Activity

set - Set

Returns:

The number of the occurrence of the set in the split multiset

getActivityCount

public long getActivityCount(java.lang.String activity)

Return the total number of appearances of the activity in the log

Parameters:

activity -

Returns:

The total number of appearances of the activity in the log

add

public void add(HadoopAnnotatedDGraph a_dgraph)

Add data from the parameter graph to the actual graph

Parameters:

a_dgraph - Annotated dependency graph

read

public boolean read(java.lang.String filename)

Read a dependency graph from an input file

Overrides:

read in class HadoopDGraph

Parameters:

filename - Input filename with the dependency graph

Returns:

True if the dependency graph has been read correctly

processSetString

protected java.util.Set<java.lang.String> processSetString(java.lang.String string_set)

Transform the set represented as a string to a Set object

Parameters:

string_set - Set as a string

Returns:

a Set Object with the elements in the string set

getStartActivities

public java.util.Set<java.lang.String> getStartActivities()

A set with the start activities

Returns:

A set with the start activities

getIntermediateActivities

public java.util.Set<java.lang.String> getIntermediateActivities()

A set with the intermediate activities

Returns:

A set with the intermediate activities

getEndActivities

public java.util.Set<java.lang.String> getEndActivities()

A set with the end activities

Returns:

A set with the end activities

activityAsString

public java.lang.String activityAsString(java.lang.String act)

toString

public java.lang.String toString()

Overrides:

toString in class HadoopDGraph

getStartCount

public long getStartCount(java.lang.String activity)

Return the number of times the activity is the start activity

Parameters:

activity - Activity

Returns:

The number of times the activity is the start activity

getEndCount

public long getEndCount(java.lang.String activity)

Return the number of times the activity is the end activity

Parameters:

activity - Activity

Returns:

The number of times the activity is the end activity