public class LocalValidator
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static int |
BATCHSIZE |
| Constructor and Description |
|---|
LocalValidator(java.lang.String validatorHostname) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Queue<ValidationRequest> |
fetchBatch() |
java.lang.String |
getStats() |
boolean |
isBatchReady() |
void |
notifyWaitingThreads() |
void |
processResponse(java.lang.String tid,
ValidateResponse response,
RWSetInfo rwSet) |
ValidateResponse |
validate(java.lang.String tid,
long startTS,
RWSetInfo rwSet,
LoadInfo myLoadInfo) |
public ValidateResponse validate(java.lang.String tid, long startTS, RWSetInfo rwSet, LoadInfo myLoadInfo)
public void processResponse(java.lang.String tid,
ValidateResponse response,
RWSetInfo rwSet)
public boolean isBatchReady()
public java.util.Queue<ValidationRequest> fetchBatch()
public void notifyWaitingThreads()
public java.lang.String getStats()