beehive.workpool

Class ValidationServiceImpl

java.lang.Object

beehive.workpool.ValidationServiceImpl

All Implemented Interfaces:

ValidationService, Remote

public class ValidationServiceImpl
extends Object
implements ValidationService

Created by khand055 on 4/4/17.

Field Summary

Fields

Modifier and Type	Field and Description
LinkedBlockingQueue<ValidationService_thrift.Client>	clientHandles
int[]	partitionedGraphHostNodesTable
static String	RPC_MECHANISM
Map<Integer,String>	serverGroup
Map<Integer,LinkedBlockingQueue<ValidationService_thrift.Client>>	serviceThreadPools
static int	STS_MANAGER

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
int	getServerFromNodeKey(long nodeId)
long	getSTS()
void	registerClientHandle()
void	registerClientHandleReplicatedValidation()
long	reportCompletion(long commitTS)
long	reportCompletion(Vector<Long> commitTSList)
ValidateResponse	validate(long startTS, RWSetInfo rwSet, LoadInfo myLoad)
Hashtable<String,ValidateResponse>	validateBatch(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

STS_MANAGER

public static final int STS_MANAGER

See Also:

Constant Field Values

partitionedGraphHostNodesTable

public int[] partitionedGraphHostNodesTable

RPC_MECHANISM

public static String RPC_MECHANISM

clientHandles

public LinkedBlockingQueue<ValidationService_thrift.Client> clientHandles

serviceThreadPools

public Map<Integer,LinkedBlockingQueue<ValidationService_thrift.Client>> serviceThreadPools

serverGroup

public Map<Integer,String> serverGroup

Constructor Detail

ValidationServiceImpl

public ValidationServiceImpl(String validationHostDetail,
                             int[] partitionedGraphHostNodesTable)
                      throws IOException

Throws:

IOException

Method Detail

registerClientHandle

public void registerClientHandle()

registerClientHandleReplicatedValidation

public void registerClientHandleReplicatedValidation()

validate

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

Specified by:

validate in interface ValidationService

Throws:

RemoteException

getServerFromNodeKey

public int getServerFromNodeKey(long nodeId)

validateBatch

public Hashtable<String,ValidateResponse> validateBatch(Queue<ValidationRequest> requestBatch,
                                                        LoadInfo myLoad)
                                                 throws RemoteException

Specified by:

validateBatch in interface ValidationService

Throws:

RemoteException

getSTS

public long getSTS()
            throws RemoteException

Specified by:

getSTS in interface ValidationService

Throws:

RemoteException

reportCompletion

public long reportCompletion(long commitTS)
                      throws RemoteException

Specified by:

reportCompletion in interface ValidationService

Throws:

RemoteException

reportCompletion

public long reportCompletion(Vector<Long> commitTSList)
                      throws RemoteException

Specified by:

reportCompletion in interface ValidationService

Throws:

RemoteException