Package org.aksw.iguana.cc.worker.impl

Class CLIInputFileWorker

java.lang.Object

org.aksw.iguana.cc.worker.AbstractWorker

org.aksw.iguana.cc.worker.AbstractRandomQueryChooserWorker

org.aksw.iguana.cc.worker.impl.MultipleCLIInputWorker

org.aksw.iguana.cc.worker.impl.CLIInputFileWorker

All Implemented Interfaces:

java.lang.Runnable, Worker

@Shorthand("CLIInputFileWorker")
public class CLIInputFileWorker
extends MultipleCLIInputWorker

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. also assumes that the query has to be read from a file instead of plain input This worker can be set to be created multiple times in the background if one process will throw an error, a backup process was already created and can be used. This is handy if the process won't just prints an error message, but simply exits.

Constructor Summary

Constructors

Constructor

Description

CLIInputFileWorker(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 numberOfProcesses, java.lang.String directory, java.lang.Integer timeOut, java.lang.Integer timeLimit, java.lang.Integer fixedLatency, java.lang.Integer gaussianLatency, java.lang.Integer workerID)

Method Summary

Methods inherited from class org.aksw.iguana.cc.worker.impl.MultipleCLIInputWorker

executeQuery, stopSending

Methods inherited from class org.aksw.iguana.cc.worker.AbstractRandomQueryChooserWorker

getNextQuery, setQueriesList

Methods inherited from class org.aksw.iguana.cc.worker.AbstractWorker

addResults, getExecutedQueries, getNoOfQueries, getQueriesFileName, hasExecutedNoOfQueryMixes, isTerminated, popQueryResults, run, startWorker, waitTimeMs

Methods inherited from class java.lang.Object

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

Constructor Detail

CLIInputFileWorker

public CLIInputFileWorker(java.lang.String taskID,
                          Connection connection,
                          java.lang.String queriesFile,
                          java.lang.String initFinished,
                          java.lang.String queryFinished,
                          java.lang.String queryError,
                          @Nullable
                          java.lang.Integer numberOfProcesses,
                          java.lang.String directory,
                          @Nullable
                          java.lang.Integer timeOut,
                          @Nullable
                          java.lang.Integer timeLimit,
                          @Nullable
                          java.lang.Integer fixedLatency,
                          @Nullable
                          java.lang.Integer gaussianLatency,
                          java.lang.Integer workerID)