Package org.processmining.plugins.inductiveVisualMiner.chain

Class DataChainInternal<C,P>

java.lang.Object

org.processmining.plugins.inductiveVisualMiner.chain.DataChainInternal<C,P>

Type Parameters:

P - panel

C - configuration

public class DataChainInternal<C,P>
extends java.lang.Object

This is the actual data chain that handles execution of computations and updating of the gui. It is to be accessed using DataChainImplNonBlocking, as this class is not thread safe.

Author:

sander

Field Summary

Fields

Modifier and Type	Field	Description
gnu.trove.map.hash.THashMap<DataChainLinkComputation<C>,IvMCanceller>	executionCancellers	Idea: each execution of a chain link has its own canceller.
DataState	state

Constructor Summary

Constructors

Constructor	Description
DataChainInternal(DataChainImplNonBlocking<C,P> parentChain, DataState state, org.processmining.framework.plugin.ProMCanceller canceller, java.util.concurrent.Executor executor, C configuration, P panel)

Method Summary

Modifier and Type	Method	Description
static boolean	contains(DataChainLink<?>[] haystack, DataChainLink<?> needle)
static boolean	contains(IvMObject<?>[] haystack, IvMObject<?> needle)
void	executeLink(DataChainLink<C> chainLink)
DataChainLink<C>	getChainLink(java.lang.Class<? extends DataChainLink<C>> clazz)
void	getObjectValues(IvMObject<?>[] objects, FutureImpl values)
void	processOutputsOfChainLink(IvMCanceller canceller, DataChainLinkComputation<?> chainLink, IvMObjectValues outputs)
void	register(DataChainLink<C> chainLink)
<O> void	setFixedObject(IvMObject<O> object, O value)	Sets an object such that it cannot be changed anymore.
<O> void	setObject(IvMObject<O> objectName, O object)	Sets an object and starts executing the chain accordingly.
org.processmining.plugins.graphviz.dot.Dot	toDot()

Methods inherited from class java.lang.Object

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

Field Detail

state

public final DataState state

executionCancellers

public final gnu.trove.map.hash.THashMap<DataChainLinkComputation<C>,IvMCanceller> executionCancellers

Idea: each execution of a chain link has its own canceller. As long as this canceller is not cancelled, the job is still valid.

Constructor Detail

DataChainInternal

public DataChainInternal(DataChainImplNonBlocking<C,P> parentChain,
                         DataState state,
                         org.processmining.framework.plugin.ProMCanceller canceller,
                         java.util.concurrent.Executor executor,
                         C configuration,
                         P panel)

Method Detail

register

public void register(DataChainLink<C> chainLink)

getChainLink

public DataChainLink<C> getChainLink(java.lang.Class<? extends DataChainLink<C>> clazz)

setObject

public <O> void setObject(IvMObject<O> objectName,
                          O object)

Sets an object and starts executing the chain accordingly.

setFixedObject

public <O> void setFixedObject(IvMObject<O> object,
                               O value)

Sets an object such that it cannot be changed anymore. It will execute the chain for this call, but afterwards this object will not trigger anything anymore. Chain link computations that have this object as an output will not be executed.

Parameters:

object -

value -

contains

public static boolean contains(DataChainLink<?>[] haystack,
                               DataChainLink<?> needle)

contains

public static boolean contains(IvMObject<?>[] haystack,
                               IvMObject<?> needle)

executeLink

public void executeLink(DataChainLink<C> chainLink)

processOutputsOfChainLink

public void processOutputsOfChainLink(IvMCanceller canceller,
                                      DataChainLinkComputation<?> chainLink,
                                      IvMObjectValues outputs)

getObjectValues

public void getObjectValues(IvMObject<?>[] objects,
                            FutureImpl values)

toDot

public org.processmining.plugins.graphviz.dot.Dot toDot()