beehive.validation

Class ValidationServiceImpl

java.lang.Object

beehive.validation.ValidationServiceImpl

All Implemented Interfaces:

ValidationService, java.rmi.Remote

public class ValidationServiceImpl
extends java.lang.Object
implements ValidationService

Created by khand055 on 4/4/17.

Field Summary

Fields

Modifier and Type	Field and Description
int[]	partitionedGraphHostNodesTable
static java.lang.String	RPC_MECHANISM

Constructor Summary

Constructors

Constructor and Description
ValidationServiceImpl(java.lang.String validationHostDetail, int[] partitionedGraphHostNodesTable)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Field Detail

partitionedGraphHostNodesTable

public int[] partitionedGraphHostNodesTable

RPC_MECHANISM

public static java.lang.String RPC_MECHANISM

Constructor Detail

ValidationServiceImpl

public ValidationServiceImpl(java.lang.String validationHostDetail,
                             int[] partitionedGraphHostNodesTable)
                      throws java.io.IOException

Throws:

java.io.IOException

Method Detail

registerClientHandle

public void registerClientHandle()

registerClientHandleReplicatedValidation

public void registerClientHandleReplicatedValidation()

validate

public ValidateResponse validate(long startTS,
                                 RWSetInfo rwSet,
                                 LoadInfo myLoad)
                          throws java.rmi.RemoteException

Specified by:

validate in interface ValidationService

Throws:

java.rmi.RemoteException

getServerFromNodeKey

public int getServerFromNodeKey(long nodeId)

validateBatch

public java.util.Hashtable<java.lang.String,ValidateResponse> validateBatch(java.util.Queue<ValidationRequest> requestBatch,
                                                                            LoadInfo myLoad)
                                                                     throws java.rmi.RemoteException

Specified by:

validateBatch in interface ValidationService

Throws:

java.rmi.RemoteException

checkPoint

public void checkPoint()
                throws java.rmi.RemoteException

Specified by:

checkPoint in interface ValidationService

Throws:

java.rmi.RemoteException

getSTS

public long getSTS()
            throws java.rmi.RemoteException

Specified by:

getSTS in interface ValidationService

Throws:

java.rmi.RemoteException

reportCompletion

public long reportCompletion(long commitTS)
                      throws java.rmi.RemoteException

Specified by:

reportCompletion in interface ValidationService

Throws:

java.rmi.RemoteException

reportCompletion

public long reportCompletion(java.util.Vector<java.lang.Long> commitTSList)
                      throws java.rmi.RemoteException

Specified by:

reportCompletion in interface ValidationService

Throws:

java.rmi.RemoteException