G
- The graph that is processed by this filterV
- The vertex type of the graphE
- The edge type of the graphO
- The type of the graph's elements originspublic abstract class AbstractGraphFilter<G extends AbstractGraph<V,E,O>,V extends AbstractVertex<V,E,O>,E extends AbstractEdge<V,E,O>,O>
extends teetime.framework.AbstractConsumerStage<G>
Constructor and Description |
---|
AbstractGraphFilter()
Creates a new filter with the given configuration.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute(G graph)
Processes the given graph.
|
protected abstract IOriginRetentionPolicy |
getDesiredOriginRetentionPolicy() |
teetime.framework.OutputPort<G> |
getOutputPort() |
protected abstract G |
performConcreteGraphProcessing(G graph)
This method encapsulates the concrete graph processing performed by the concrete filters.
|
createInputPort, execute, getInputPort
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
public AbstractGraphFilter()
protected abstract IOriginRetentionPolicy getDesiredOriginRetentionPolicy() throws AnalysisConfigurationException
AnalysisConfigurationException
protected void execute(G graph) throws java.lang.Exception
execute
in class teetime.framework.AbstractConsumerStage<G extends AbstractGraph<V,E,O>>
graph
- The graph to processjava.lang.Exception
public teetime.framework.OutputPort<G> getOutputPort()
Copyright 2021 Kieker Project, http://kieker-monitoring.net