Package org.aksw.iguana.cc.tasks.impl

Class Stresstest

  • All Implemented Interfaces:
    Task
    @Shorthand("Stresstest")
public class Stresstest
extends AbstractTask
    Stresstest. Will stresstest a connection using several Workers (simulated Users) each in one thread.

    • Constructor Summary

      Constructors 
      Constructor Description
      Stresstest​(java.lang.Integer timeLimit, java.util.ArrayList workers, java.util.LinkedHashMap queryHandler)  
      Stresstest​(java.lang.Integer timeLimit, java.util.ArrayList workers, java.util.LinkedHashMap queryHandler, java.util.LinkedHashMap warmup)  
      Stresstest​(java.util.ArrayList workers, java.util.LinkedHashMap queryHandler, java.lang.Integer noOfQueryMixes)  
      Stresstest​(java.util.ArrayList workers, java.util.LinkedHashMap queryHandler, java.util.LinkedHashMap warmup, java.lang.Integer noOfQueryMixes)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void addMetaData()
      Add extra Meta Data
      void close()
      Will close the Task and post process everything (e.g.
      void execute()
      Will execute the Task
      long getExecutedQueries()  
      void init​(java.lang.String[] ids, java.lang.String dataset, Connection connection)
      Will initialize the task

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • Stresstest

        public Stresstest​(java.lang.Integer timeLimit,
                  java.util.ArrayList workers,
                  java.util.LinkedHashMap queryHandler)
           throws java.io.FileNotFoundException
        Throws:
        java.io.FileNotFoundException

      • Stresstest

        public Stresstest​(java.lang.Integer timeLimit,
                  java.util.ArrayList workers,
                  java.util.LinkedHashMap queryHandler,
                  java.util.LinkedHashMap warmup)
           throws java.io.FileNotFoundException
        Throws:
        java.io.FileNotFoundException

      • Stresstest

        public Stresstest​(java.util.ArrayList workers,
                  java.util.LinkedHashMap queryHandler,
                  java.lang.Integer noOfQueryMixes)
           throws java.io.FileNotFoundException
        Throws:
        java.io.FileNotFoundException

      • Stresstest

        public Stresstest​(java.util.ArrayList workers,
                  java.util.LinkedHashMap queryHandler,
                  java.util.LinkedHashMap warmup,
                  java.lang.Integer noOfQueryMixes)
           throws java.io.FileNotFoundException
        Throws:
        java.io.FileNotFoundException

    • Method Detail

      • init

        public void init​(java.lang.String[] ids,
                 java.lang.String dataset,
                 Connection connection)
        Description copied from interface: Task
        Will initialize the task
        Specified by:
        init in interface Task
        Overrides:
        init in class AbstractTask
        Parameters:
        ids - normally the suiteID, experimentID, taskID
        dataset - the dataset name
        connection - the current connection to execute the task against

      • execute

        public void execute()
        Description copied from interface: Task
        Will execute the Task

      • close

        public void close()
        Description copied from interface: Task
        Will close the Task and post process everything (e.g. send the end flag to the rabbit mq queue)
        Specified by:
        close in interface Task
        Overrides:
        close in class AbstractTask

      • getExecutedQueries

        public long getExecutedQueries()