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, getInputPortabort, 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, workCompletedpublic AbstractGraphFilter()
protected abstract IOriginRetentionPolicy getDesiredOriginRetentionPolicy() throws AnalysisConfigurationException
AnalysisConfigurationExceptionprotected 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.Exceptionpublic teetime.framework.OutputPort<G> getOutputPort()
Copyright 2021 Kieker Project, http://kieker-monitoring.net