Package kieker.analysis.generic.clustering

Class DataCollectorStage<T>

java.lang.Object
teetime.framework.AbstractStage
kieker.analysis.generic.clustering.DataCollectorStage<T>
Type Parameters:
T - type of the objects collected
public class DataCollectorStage<T> extends teetime.framework.AbstractStage
Collect objects until a time trigger has been received or the maximal amount of events have been collected. On termination, it sends out its remaining content
Since:
2.0.0
Author:
Lars Jürgensen

  • Field Summary

    Fields inherited from class teetime.framework.AbstractStage

    logger

  • Constructor Summary

    Constructors
    Constructor
    Description
    DataCollectorStage()
    Collect behavior models and send them based on an external time trigger to the mtree generation and a clustering stage.
    DataCollectorStage(int amount)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    execute()
     
    teetime.framework.InputPort<T>
    getDataInputPort()
     
    teetime.framework.OutputPort<List<T>>
    getmTreeOutputPort()
     
    teetime.framework.OutputPort<List<T>>
    getOpticsOutputPort()
     
    teetime.framework.InputPort<Long>
    getTimeTriggerInputPort()
     
    protected void
    onTerminating()
     

    Methods inherited from class teetime.framework.AbstractStage

    abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • DataCollectorStage

      public DataCollectorStage()
      Collect behavior models and send them based on an external time trigger to the mtree generation and a clustering stage.

    • DataCollectorStage

      public DataCollectorStage(int amount)

  • Method Details

    • execute

      protected void execute() throws Exception
      Specified by:
      execute in class teetime.framework.AbstractStage
      Throws:
      Exception

    • onTerminating

      protected void onTerminating()
      Overrides:
      onTerminating in class teetime.framework.AbstractStage

    • getDataInputPort

      public teetime.framework.InputPort<T> getDataInputPort()

    • getTimeTriggerInputPort

      public teetime.framework.InputPort<Long> getTimeTriggerInputPort()

    • getmTreeOutputPort

      public teetime.framework.OutputPort<List<T>> getmTreeOutputPort()

    • getOpticsOutputPort

      public teetime.framework.OutputPort<List<T>> getOpticsOutputPort()