beehive.validation

Class GlobalValidationService

java.lang.Object

beehive.validation.GlobalValidationService

All Implemented Interfaces:

ValidationService_thrift.Iface, ValidationService, java.rmi.Remote

public class GlobalValidationService
extends java.lang.Object
implements ValidationService, ValidationService_thrift.Iface

Field Summary

Fields

Modifier and Type	Field and Description
Config	configParams
static int	DISPATCH_BATCH_SIZE
static long	idleTimeInterval
boolean	locality
boolean	logging
static int	NOAFFINITY_BATCH_SIZE
static long	printProgressInterval

Constructor Summary

Constructors

Constructor and Description
GlobalValidationService()

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,ValidateResponse_thrift>	batchValidate_thrift(java.util.List<ValidationRequest_thrift> requests)
void	checkPoint()
long	getSTS_thrift()
long	getSTS()
static void	main(java.lang.String[] args)
long	reportCompletion_thrift(long commitTS)
long	reportCompletion(long commitTS)
long	reportCompletion(java.util.Vector<java.lang.Long> commitTSList)
long	reportCompletionBatch_thrift(java.util.List<java.lang.Long> commitTSList)
ValidateResponse_thrift	validate_thrift(long startTS, RWSetInfo_thrift rwSet)
ValidateResponse	validate(long startTS, RWSetInfo rwSetInfo, LoadInfo myLoadInfo)
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

configParams

public Config configParams

DISPATCH_BATCH_SIZE

public static int DISPATCH_BATCH_SIZE

NOAFFINITY_BATCH_SIZE

public static int NOAFFINITY_BATCH_SIZE

printProgressInterval

public static long printProgressInterval

idleTimeInterval

public static long idleTimeInterval

locality

public boolean locality

logging

public boolean logging

Constructor Detail

GlobalValidationService

public GlobalValidationService()
                        throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

Method Detail

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

validate

public ValidateResponse validate(long startTS,
                                 RWSetInfo rwSetInfo,
                                 LoadInfo myLoadInfo)
                          throws java.rmi.RemoteException

Specified by:

validate in interface ValidationService

Throws:

java.rmi.RemoteException

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

getSTS_thrift

public long getSTS_thrift()

Specified by:

getSTS_thrift in interface ValidationService_thrift.Iface

validate_thrift

public ValidateResponse_thrift validate_thrift(long startTS,
                                               RWSetInfo_thrift rwSet)
                                        throws org.apache.thrift.TException

Specified by:

validate_thrift in interface ValidationService_thrift.Iface

Throws:

org.apache.thrift.TException

reportCompletion_thrift

public long reportCompletion_thrift(long commitTS)

Specified by:

reportCompletion_thrift in interface ValidationService_thrift.Iface

reportCompletionBatch_thrift

public long reportCompletionBatch_thrift(java.util.List<java.lang.Long> commitTSList)

Specified by:

reportCompletionBatch_thrift in interface ValidationService_thrift.Iface

batchValidate_thrift

public java.util.Map<java.lang.String,ValidateResponse_thrift> batchValidate_thrift(java.util.List<ValidationRequest_thrift> requests)

Specified by:

batchValidate_thrift in interface ValidationService_thrift.Iface

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception