String myURL
int myId
ConcurrentHashMap<K,V> table
ConcurrentHashMap<K,V> locationTable
ConcurrentHashMap<K,V> cacheTable
ConcurrentHashMap<K,V> metaDataTable
HashSet<E> lockedObjects
int changeMasterCount
StatContainer statCachedCopyNumTimesUsed
StatContainer statCountInvalidateCallSize
StatContainer statInvalidateTime
StatContainer statGetCallTime
StatContainer statPutCallTime
StatContainer statGetNodeForCachingTime
StatContainer statGetNodesForCachingCallSize
StatContainer invalidateCacheCopiesCallSize
StatContainer statInvalidateCacheCopiesTime
int statCountNumCacheStarts
int statCountNumCachePuts
int statCountNumCacheInvalidations
boolean useCaching
Logger log
boolean recordStats
int cacheInvalidationScheme
LinkedBlockingQueue<E> cacheUsageQueue
int CACHE_TABLE_SIZE
int CACHE_WINDOW
float CACHE_CLEANUP_TARGET
boolean USE_NODEDATA_REFLECTION
int numServers
ConcurrentHashMap<K,V> servers
boolean canonicalHostNames
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionString key
long storageSystemThreadId
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionResultObject_thrift success
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionNodeData_thrift n
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionResultObject_thrift success
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionint nodeId
String serverName
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionint nodeId
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionResultObject_thrift success
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionString key
Node_thrift value
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionResultObject_thrift success
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionint nodeId
String serverName
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionResultObject_thrift success
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionNodeData_thrift n
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionResultObject_thrift success
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong startTS
long transactionId
boolean bReleaseLock
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionPeerResponse_thrift success
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong startTS
long commitTS
long transactionId
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionPeerResponse_thrift success
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong success
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong commitTS
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong success
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong success
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong startTS
RWSetInfo_thrift rwSet
long transactionId
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionPeerResponse_thrift success
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionint responseType
int serverId
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionint status
String statuscode
Node_thrift n
NodeData_thrift nd
String nodeId
String location
byte __isset_bitfield
ResultObject_thrift._Fields[] optionals
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionString tid
RWSetInfo_thrift rwSet
long startTS
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong success
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong commitTS
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong success
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionprivate void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong success
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionlong startTS
RWSetInfo_thrift rwSet
byte __isset_bitfield
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void writeObject(ObjectOutputStream out) throws IOException
IOExceptionValidateResponse_thrift success
int numNodes
int totalEdges
int internalEdges
int outgoingEdges
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionlong lastUpdateTime
long startTime
long totalArrivals
long totalDepartures
long currentCount
long totalIdleTime
double cumulativeArea
boolean start
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionfloat sum
float squaredSum
float numSamples
float mean
float median
float stdDev
float min
float max
Vector<E> values
Vector<E> sortedValues
boolean sorted
boolean medianCalculated
int samplesLimit
String taskId
String nodeId
TransactionInfo txnInfo
String phase
int affinityLevel
String targetLocation
int status
int retryCount
long initTime
long scheduleTime
String tid
long startTS
long commitTS
long stableTS
int myId
ReplicationConfig replicaConfig
TimestampManager timestampManager
ExecutorService globalExecutors
Validator validator
Logger logger
LinkedBlockingQueue<E> pendingReportCompletionQueue
RMIAdapter rmiAdapter
PrintStream ps
boolean bDebug
String rpcMechanism
boolean bWriteStatsToFile
Config configParams
AtomicLong clientRequestCount
AtomicLong clientCommitCount
AtomicLong clientAbortCount
AtomicLong peerRequestCount
AtomicLong peerCommitCount
AtomicLong peerAbortCount
long transactionId
Map<K,V> pendingValidationRequest
int responseType
int serverId
LocalWorkpoolImpl workpool
StorageSystem dataStorage
boolean debug
RWSetInfo rwsetinfo
Hashtable<K,V> updatedNodes
Hashtable<K,V> updatedNodesData
HashSet<E> tasksCreated
Config configParams
int workerId
boolean master
long startTime
long endTime
WorkerStatus workerStatus
Logger log
StatContainer statGetTaskTime
StatContainer statDoTaskTime
StatContainer statComputeTime
StatContainer statValidateTime
StatContainer statCommitTaskTime
int workerId
int status
TransactionInfo currentTxnInfo
String taskId
ConcurrentHashMap<K,V> workpoolHandleTable
ConcurrentHashMap<K,V> activeTaskPool
ConcurrentHashMap<K,V> readyTaskPool
QueueStat readyPoolStats
QueueStat activePoolStats
ConcurrentHashMap<K,V> loadInfoTable
ConcurrentHashMap<K,V> weakAffinityTable
ConcurrentHashMap<K,V> strongAffinityTable
Vector<E> noAffinityTaskList
int task_count
ConcurrentHashMap<K,V> loadCountTable
boolean isConcurrentValidator
boolean isTruncationEnabled
TimestampManager timestampMgr
ConcurrentValidatorWithTruncation concurrentValidatorWithTruncation
ConcurrentValidator concurrentValidator
Validator validator
Config configParams
Logger logger
Object readyPoolLock
int status
boolean locality
boolean logging
boolean speculativeChecking
StatContainer specCheckTimeStats
StatContainer completeCheckTimeStats
QueueStat pendingValQStats
int totalCommits
int totalAborts
int totalCompleted
int windowCommits
int windowAborts
int windowCompleted
long lastActTime
long prevTime
boolean canonicalHostNames
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionString globalWpoolURL
ValidationService validationService
String myURL
LocalValidator localValidator
ConcurrentHashMap<K,V> wpoolHandles
ConcurrentHashMap<K,V> loadInfoTable
Vector<E> peerList
LoadInfo myLoadInfo
LoadDistributor loadDistributor
LoadDistributorV2 loadDistributorV2
StatContainer localDepStats
ConcurrentHashMap<K,V> activeTaskPool
LinkedBlockingQueue<E> readyTaskPool
ConcurrentHashMap<K,V> barrierStatus
int barrierCount
StringBuffer logBuffer
Config configParams
String modelType
long lastSTSUpdateTime
long lastLoadVectorUpdateTime
int status
long task_count
long abort_count
float abortRatio
long prevPrintTime
long prevMonitorTime
Long latestSTS
Long tid
boolean pullTask
boolean logging
int progressMonitorInterval
int printStatusInterval
String myHost
String masterHost
boolean master
int termQueryTS
int termQueryCounter
int workerCount
int totalTasks
int totalAborts
HashSet<E> committedTSList
Integer abortOnStartCounter
boolean canonicalHostNames
float abortRatio
int activeTask
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionStatusType status
Vector<E> taskList
Task task
long latestSTS
int timeout