Class CLIInputWorker

  • All Implemented Interfaces:
    java.lang.Runnable, Worker

    public class CLIInputWorker
    extends AbstractRandomQueryChooserWorker
    Worker to execute a query against a CLI process, the connection.service will be the command to execute the query against. Assumes that the CLI process won't stop but will just accepts queries one after another and returns the results in the CLI output.
    • Constructor Detail

      • CLIInputWorker

        public CLIInputWorker​(java.lang.String taskID,
                              Connection connection,
                              java.lang.String queriesFile,
                              java.lang.String initFinished,
                              java.lang.String queryFinished,
                              java.lang.String queryError,
                              java.lang.Integer timeOut,
                              java.lang.Integer timeLimit,
                              java.lang.Integer fixedLatency,
                              java.lang.Integer gaussianLatency,
                              java.lang.Integer workerID)
    • Method Detail

      • executeQuery

        public void executeQuery​(java.lang.String query,
                                 java.lang.String queryID)
        Description copied from interface: Worker
        This method executes a query and adds the results to the Result Processor for proper result and metric calculations. Note: Some of the Worker implementations employ background threads to process the result of the query. Due to this, this method does not return anything and each implementation of this method must also add the results to Result Processor within this method. This can be done by calling AbstractWorker.addResults(QueryExecutionStats)
        query - The query which should be executed
        queryID - the ID of the query which should be executed
      • stopSending

        public void stopSending()
        Description copied from interface: Worker
        This should stop the next sending process. If an execution started before this method was called, but answered after, it should not be counted!
        Specified by:
        stopSending in interface Worker
        stopSending in class AbstractWorker