Class AbstractTask

  • All Implemented Interfaces:
    Task
    Direct Known Subclasses:
    Stresstest

    public abstract class AbstractTask
    extends java.lang.Object
    implements Task
    Abstract Task to help create a Task. Will do the background work
    Author:
    f.conrads
    • Constructor Summary

      Constructors 
      Constructor Description
      AbstractTask()
      Creates an AbstractTask with the TaskID
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void addMetaData()
      Will add the Meta data for the start which then can be saved into the triple based storages
      void close()
      Will close the Task and post process everything (e.g.
      void init​(java.lang.String[] ids, java.lang.String dataset, Connection con)
      Will initialize the task
      void sendResults​(java.util.Properties data)
      Will send the results to the result processing.
      void start()
      Will start the Task (sending the rabbitMQ start flag)
      • Methods inherited from class java.lang.Object

        equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface org.aksw.iguana.cc.tasks.Task

        execute
    • Constructor Detail

      • AbstractTask

        public AbstractTask()
        Creates an AbstractTask with the TaskID
    • Method Detail

      • init

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

        public void start()
        Description copied from interface: Task
        Will start the Task (sending the rabbitMQ start flag)
        Specified by:
        start in interface Task
      • sendResults

        public void sendResults​(java.util.Properties data)
                         throws java.io.IOException
        Description copied from interface: Task
        Will send the results to the result processing.
        Specified by:
        sendResults in interface Task
        Throws:
        java.io.IOException
      • 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
      • addMetaData

        public void addMetaData()
        Description copied from interface: Task
        Will add the Meta data for the start which then can be saved into the triple based storages
        Specified by:
        addMetaData in interface Task