public class ValidationServiceImpl extends java.lang.Object implements ValidationService
| Modifier and Type | Field and Description |
|---|---|
int[] |
partitionedGraphHostNodesTable |
static java.lang.String |
RPC_MECHANISM |
| Constructor and Description |
|---|
ValidationServiceImpl(java.lang.String validationHostDetail,
int[] partitionedGraphHostNodesTable) |
| Modifier and Type | Method and Description |
|---|---|
void |
checkPoint() |
int |
getServerFromNodeKey(long nodeId) |
long |
getSTS() |
void |
registerClientHandle() |
void |
registerClientHandleReplicatedValidation() |
long |
reportCompletion(long commitTS) |
long |
reportCompletion(java.util.Vector<java.lang.Long> commitTSList) |
ValidateResponse |
validate(long startTS,
RWSetInfo rwSet,
LoadInfo myLoad) |
java.util.Hashtable<java.lang.String,ValidateResponse> |
validateBatch(java.util.Queue<ValidationRequest> requestBatch,
LoadInfo myLoad) |
public int[] partitionedGraphHostNodesTable
public static java.lang.String RPC_MECHANISM
public ValidationServiceImpl(java.lang.String validationHostDetail,
int[] partitionedGraphHostNodesTable)
throws java.io.IOException
java.io.IOExceptionpublic void registerClientHandle()
public void registerClientHandleReplicatedValidation()
public ValidateResponse validate(long startTS, RWSetInfo rwSet, LoadInfo myLoad) throws java.rmi.RemoteException
validate in interface ValidationServicejava.rmi.RemoteExceptionpublic int getServerFromNodeKey(long nodeId)
public java.util.Hashtable<java.lang.String,ValidateResponse> validateBatch(java.util.Queue<ValidationRequest> requestBatch, LoadInfo myLoad) throws java.rmi.RemoteException
validateBatch in interface ValidationServicejava.rmi.RemoteExceptionpublic void checkPoint()
throws java.rmi.RemoteException
checkPoint in interface ValidationServicejava.rmi.RemoteExceptionpublic long getSTS()
throws java.rmi.RemoteException
getSTS in interface ValidationServicejava.rmi.RemoteExceptionpublic long reportCompletion(long commitTS)
throws java.rmi.RemoteException
reportCompletion in interface ValidationServicejava.rmi.RemoteExceptionpublic long reportCompletion(java.util.Vector<java.lang.Long> commitTSList)
throws java.rmi.RemoteException
reportCompletion in interface ValidationServicejava.rmi.RemoteException