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

Class CLIInputPrefixWorker

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.CLIInputPrefixWorker

All Implemented Interfaces:

java.lang.Runnable, Worker

@Shorthand("CLIInputPrefixWorker")
public class CLIInputPrefixWorker
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 prefixed and suffixed. For example: SPARQL SELECT * {?s ?p ?o} ; whereas 'SPARQL' is the prefix and ';' is the suffix. 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

CLIInputPrefixWorker(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 queryPrefix, java.lang.String querySuffix, 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

CLIInputPrefixWorker

public CLIInputPrefixWorker(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 queryPrefix,
                            java.lang.String querySuffix,
                            @Nullable
                            java.lang.Integer timeOut,
                            @Nullable
                            java.lang.Integer timeLimit,
                            @Nullable
                            java.lang.Integer fixedLatency,
                            @Nullable
                            java.lang.Integer gaussianLatency,
                            java.lang.Integer workerID)