Class AbstractDataflowAssemblerStage<I,O>
java.lang.Object
teetime.framework.AbstractStage
teetime.framework.AbstractConsumerStage<I>
teetime.stage.basic.AbstractTransformation<I,O>
kieker.analysis.architecture.recovery.storage.AbstractDataflowAssemblerStage<I,O>
- Type Parameters:
I
- Input data typeO
- Output data type
- All Implemented Interfaces:
teetime.stage.basic.ITransformation<I,O>
- Direct Known Subclasses:
ExecutionModelDataflowAssemblerStage
public abstract class AbstractDataflowAssemblerStage<I,O>
extends teetime.stage.basic.AbstractTransformation<I,O>
Assembler stage based on dataflow events.
- Since:
- 1.1
- Author:
- Reiner Jung
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.String
sourceLabel
protected SourceModel
sourceModel
-
Constructor Summary
Constructors Constructor Description AbstractDataflowAssemblerStage(SourceModel sourceModel, java.lang.String sourceLabel)
-
Method Summary
Modifier and Type Method Description protected void
addObjectToSource(org.eclipse.emf.ecore.EObject object)
Methods inherited from class teetime.framework.AbstractConsumerStage
createInputPort, execute, execute, getInputPort
Methods inherited from class teetime.framework.AbstractStage
abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
-
Field Details
-
sourceModel
-
sourceLabel
protected final java.lang.String sourceLabel
-
-
Constructor Details
-
Method Details
-
addObjectToSource
protected void addObjectToSource(org.eclipse.emf.ecore.EObject object)
-