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

Class HttpWorker

java.lang.Object

org.aksw.iguana.cc.worker.AbstractWorker

org.aksw.iguana.cc.worker.AbstractRandomQueryChooserWorker

org.aksw.iguana.cc.worker.impl.HttpWorker

All Implemented Interfaces:

java.lang.Runnable, Worker

Direct Known Subclasses:

HttpGetWorker

public abstract class HttpWorker
extends AbstractRandomQueryChooserWorker

Abstract HTTP worker

Constructor Summary

Constructors

Constructor	Description
HttpWorker(java.lang.String taskID, Connection connection, java.lang.String queriesFile, java.lang.Integer timeOut, java.lang.Integer timeLimit, java.lang.Integer fixedLatency, java.lang.Integer gaussianLatency, java.lang.String workerType, java.lang.Integer workerID)

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.ConcurrentMap<QueryResultHashKey,java.lang.Long>	getProcessedResults()
void	shutdownResultProcessor()

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, stopSending, waitTimeMs

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.aksw.iguana.cc.worker.Worker

executeQuery

Constructor Detail

HttpWorker

public HttpWorker(java.lang.String taskID,
                  Connection connection,
                  java.lang.String queriesFile,
                  @Nullable
                  java.lang.Integer timeOut,
                  @Nullable
                  java.lang.Integer timeLimit,
                  @Nullable
                  java.lang.Integer fixedLatency,
                  @Nullable
                  java.lang.Integer gaussianLatency,
                  java.lang.String workerType,
                  java.lang.Integer workerID)

Method Detail

getProcessedResults

public java.util.concurrent.ConcurrentMap<QueryResultHashKey,java.lang.Long> getProcessedResults()

shutdownResultProcessor

public void shutdownResultProcessor()