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
-
-
-
-
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)
-
-