Serialized Form

Package beehive.server

Class beehive.server.HashtableServerImpl extends java.rmi.server.UnicastRemoteObject implements Serializable

Serialized Fields

myURL
```
java.lang.String myURL
```
myId
```
int myId
```

table

java.util.concurrent.ConcurrentHashMap<K,V> table

locationTable

java.util.concurrent.ConcurrentHashMap<K,V> locationTable

cacheTable

java.util.concurrent.ConcurrentHashMap<K,V> cacheTable

metaDataTable

java.util.concurrent.ConcurrentHashMap<K,V> metaDataTable

lockedObjects
```
java.util.HashSet<E> lockedObjects
```
changeMasterCount
```
int changeMasterCount
```

statCachedCopyNumTimesUsed

StatContainer statCachedCopyNumTimesUsed

statCountInvalidateCallSize

StatContainer statCountInvalidateCallSize

statInvalidateTime
```
StatContainer statInvalidateTime
```
statGetCallTime
```
StatContainer statGetCallTime
```
statPutCallTime
```
StatContainer statPutCallTime
```
statGetNodeForCachingTime
```
StatContainer statGetNodeForCachingTime
```

statGetNodesForCachingCallSize

StatContainer statGetNodesForCachingCallSize

invalidateCacheCopiesCallSize

StatContainer invalidateCacheCopiesCallSize

statInvalidateCacheCopiesTime

StatContainer statInvalidateCacheCopiesTime

statCountNumCacheStarts
```
int statCountNumCacheStarts
```
statCountNumCachePuts
```
int statCountNumCachePuts
```
statCountNumCacheInvalidations
```
int statCountNumCacheInvalidations
```
useCaching
```
boolean useCaching
```
log
```
Logger log
```
recordStats
```
boolean recordStats
```
cacheInvalidationScheme
```
int cacheInvalidationScheme
```

cacheUsageQueue

java.util.concurrent.LinkedBlockingQueue<E> cacheUsageQueue

CACHE_TABLE_SIZE
```
int CACHE_TABLE_SIZE
```
CACHE_WINDOW
```
int CACHE_WINDOW
```
CACHE_CLEANUP_TARGET
```
float CACHE_CLEANUP_TARGET
```
numServers
```
int numServers
```

servers

java.util.concurrent.ConcurrentHashMap<K,V> servers

Class beehive.server.ResultObject extends java.lang.Object implements Serializable
- Serialized Fields
  - status
```
int status
```
  - statuscode
```
java.lang.String statuscode
```
  - node
```
java.lang.Object node
```
  - nodeId
```
int nodeId
```
  - location
```
java.lang.String location
```
  - metadata
```
NodeMetadata metadata
```
Class beehive.server.ResultObjectReflection extends java.lang.Object implements Serializable
- Serialized Fields
  - node
```
NodeData node
```
  - nodeId
```
int nodeId
```
  - status
```
int status
```
  - statuscode
```
java.lang.String statuscode
```
  - location
```
java.lang.String location
```
  - metadata
```
NodeMetadata metadata
```

Package beehive.util
- Class beehive.util.ClusterMeasures extends java.lang.Object implements Serializable
  - Serialized Fields
    - numNodes
```
int numNodes
```
    - totalEdges
```
int totalEdges
```
    - internalEdges
```
int internalEdges
```
    - outgoingEdges
```
int outgoingEdges
```
- Class beehive.util.Edge extends java.lang.Object implements Serializable
  - Serialized Fields
    - neighborId
```
int neighborId
```
- Class beehive.util.Node extends java.lang.Object implements Serializable
  - Serialized Fields
    - nodeId
```
int nodeId
```
    - TS
```
long TS
```
    - neighbors
```
java.util.Hashtable<K,V> neighbors
```
- Class beehive.util.NodeData extends java.lang.Object implements Serializable
  - Serialized Fields
    - nodeId
```
int nodeId
```
    - TS
```
long TS
```
    - properties
```
java.util.Map<K,V> properties
```
- Class beehive.util.NodeMetadata extends java.lang.Object implements Serializable
  - Serialized Fields
    - nodeID
```
java.lang.String nodeID
```
    - masterNodeID
```
java.lang.String masterNodeID
```
    - isMaster
```
boolean isMaster
```
    - cacheCopyNodes
```
java.util.List<E> cacheCopyNodes
```
    - masterCopySite
```
int masterCopySite
```
    - cachingInProgressFlag
```
long cachingInProgressFlag
```
    - numTimesUsed
```
int numTimesUsed
```
    - lastAccessedTS
```
long lastAccessedTS
```
- Class beehive.util.QueueStat extends java.lang.Object implements Serializable
  - Serialized Fields
    - lastUpdateTime
```
long lastUpdateTime
```
    - startTime
```
long startTime
```
    - totalArrivals
```
long totalArrivals
```
    - totalDepartures
```
long totalDepartures
```
    - currentCount
```
long currentCount
```
    - totalIdleTime
```
long totalIdleTime
```
    - cumulativeArea
```
double cumulativeArea
```
    - start
```
boolean start
```
- Class beehive.util.RWSetInfo extends java.lang.Object implements Serializable
  - Serialized Fields
    - readSet
```
java.util.HashSet<E> readSet
```
    - writeSet
```
java.util.HashSet<E> writeSet
```
    - unusedSet
```
java.util.HashSet<E> unusedSet
```
- Class beehive.util.StatContainer extends java.lang.Object implements Serializable
  - Serialized Fields
    - sum
```
float sum
```
    - squaredSum
```
float squaredSum
```
    - numSamples
```
float numSamples
```
    - mean
```
float mean
```
    - median
```
float median
```
    - stdDev
```
float stdDev
```
    - min
```
float min
```
    - max
```
float max
```
    - values
```
java.util.Vector<E> values
```
    - sortedValues
```
java.util.Vector<E> sortedValues
```
    - sorted
```
boolean sorted
```
    - medianCalculated
```
boolean medianCalculated
```
    - samplesLimit
```
int samplesLimit
```
- Class beehive.util.Task extends java.lang.Object implements Serializable
  - Serialized Fields
    - taskId
```
java.lang.String taskId
```
    - nodeId
```
java.lang.String nodeId
```
    - txnInfo
```
TransactionInfo txnInfo
```
    - phase
```
java.lang.String phase
```
    - affinityLevel
```
int affinityLevel
```
    - targetLocation
```
java.lang.String targetLocation
```
    - status
```
int status
```
    - retryCount
```
int retryCount
```
    - initTime
```
long initTime
```
    - scheduleTime
```
long scheduleTime
```
- Class beehive.util.TransactionInfo extends java.lang.Object implements Serializable
  - Serialized Fields
    - tid
```
java.lang.String tid
```
    - startTS
```
long startTS
```
    - commitTS
```
long commitTS
```

Package beehive.worker

Class beehive.worker.Worker extends java.rmi.server.UnicastRemoteObject implements Serializable

Serialized Fields

workpool
```
LocalWorkpoolImpl workpool
```
dataStorage
```
StorageSystem dataStorage
```
debug
```
boolean debug
```
rwsetinfo
```
RWSetInfo rwsetinfo
```
updatedNodes
```
java.util.Hashtable<K,V> updatedNodes
```

updatedNodesData

java.util.Hashtable<K,V> updatedNodesData

tasksCreated
```
java.util.HashSet<E> tasksCreated
```
configParams
```
Config configParams
```
workerId
```
int workerId
```
master
```
boolean master
```
startTime
```
long startTime
```
endTime
```
long endTime
```
workerStatus
```
WorkerStatus workerStatus
```
log
```
Logger log
```
statGetTaskTime
```
StatContainer statGetTaskTime
```
statDoTaskTime
```
StatContainer statDoTaskTime
```
statComputeTime
```
StatContainer statComputeTime
```
statValidateTime
```
StatContainer statValidateTime
```
statCommitTaskTime
```
StatContainer statCommitTaskTime
```

Class beehive.worker.WorkerStatus extends java.lang.Object implements Serializable
- Serialized Fields
  - workerId
```
int workerId
```
  - status
```
int status
```
  - currentTxnInfo
```
TransactionInfo currentTxnInfo
```
  - taskId
```
java.lang.String taskId
```

Package beehive.workpool

Class beehive.workpool.CompletionResponse extends java.lang.Object implements Serializable

Class beehive.workpool.GlobalWorkpoolImpl extends java.rmi.server.UnicastRemoteObject implements Serializable

Serialized Fields

workpoolHandleTable

java.util.concurrent.ConcurrentHashMap<K,V> workpoolHandleTable

activeTaskPool

java.util.concurrent.ConcurrentHashMap<K,V> activeTaskPool

readyTaskPool

java.util.concurrent.ConcurrentHashMap<K,V> readyTaskPool

readyPoolStats
```
QueueStat readyPoolStats
```
activePoolStats
```
QueueStat activePoolStats
```

loadInfoTable

java.util.concurrent.ConcurrentHashMap<K,V> loadInfoTable

weakAffinityTable

java.util.concurrent.ConcurrentHashMap<K,V> weakAffinityTable

strongAffinityTable

java.util.concurrent.ConcurrentHashMap<K,V> strongAffinityTable

noAffinityTaskList
```
java.util.Vector<E> noAffinityTaskList
```
task_count
```
int task_count
```

loadCountTable

java.util.concurrent.ConcurrentHashMap<K,V> loadCountTable

isConcurrentValidator
```
boolean isConcurrentValidator
```
isTruncationEnabled
```
boolean isTruncationEnabled
```
timestampMgr
```
TimestampManager timestampMgr
```

concurrentValidatorWithTruncation

ConcurrentValidatorWithTruncation concurrentValidatorWithTruncation

concurrentValidator
```
ConcurrentValidator concurrentValidator
```
validator
```
Validator validator
```
configParams
```
Config configParams
```
logger
```
Logger logger
```
readyPoolLock
```
java.lang.Object readyPoolLock
```
status
```
int status
```
locality
```
boolean locality
```
logging
```
boolean logging
```
speculativeChecking
```
boolean speculativeChecking
```
specCheckTimeStats
```
StatContainer specCheckTimeStats
```
completeCheckTimeStats
```
StatContainer completeCheckTimeStats
```
pendingValQStats
```
QueueStat pendingValQStats
```
totalCommits
```
int totalCommits
```
totalAborts
```
int totalAborts
```
totalCompleted
```
int totalCompleted
```
windowCommits
```
int windowCommits
```
windowAborts
```
int windowAborts
```
windowCompleted
```
int windowCompleted
```
lastActTime
```
long lastActTime
```
prevTime
```
long prevTime
```

Class beehive.workpool.LoadInfo extends java.lang.Object implements Serializable
- Serialized Fields
  - load
```
int load
```
  - tsMatch
```
boolean tsMatch
```
  - hostname
```
java.lang.String hostname
```

Class beehive.workpool.LocalWorkpoolImpl extends java.rmi.server.UnicastRemoteObject implements Serializable

Serialized Fields

globalWpoolURL
```
java.lang.String globalWpoolURL
```
myURL
```
java.lang.String myURL
```
globalValidator
```
ValidationService globalValidator
```
localValidator
```
LocalValidator localValidator
```

wpoolHandles

java.util.concurrent.ConcurrentHashMap<K,V> wpoolHandles

loadInfoTable

java.util.concurrent.ConcurrentHashMap<K,V> loadInfoTable

peerList
```
java.util.Vector<E> peerList
```
myLoadInfo
```
LoadInfo myLoadInfo
```
loadDistributor
```
LoadDistributor loadDistributor
```
localDepStats
```
StatContainer localDepStats
```

activeTaskPool

java.util.concurrent.ConcurrentHashMap<K,V> activeTaskPool

readyTaskPool

java.util.concurrent.LinkedBlockingQueue<E> readyTaskPool

barrierStatus

java.util.concurrent.ConcurrentHashMap<K,V> barrierStatus

barrierCount
```
int barrierCount
```
logBuffer
```
java.lang.StringBuffer logBuffer
```
configParams
```
Config configParams
```
modelType
```
java.lang.String modelType
```
lastSTSUpdateTime
```
long lastSTSUpdateTime
```
lastLoadVectorUpdateTime
```
long lastLoadVectorUpdateTime
```
status
```
int status
```
task_count
```
long task_count
```
abort_count
```
long abort_count
```
abortRatio
```
float abortRatio
```
prevPrintTime
```
long prevPrintTime
```
prevMonitorTime
```
long prevMonitorTime
```
latestSTS
```
java.lang.Long latestSTS
```
tid
```
java.lang.Long tid
```
pullTask
```
boolean pullTask
```
logging
```
boolean logging
```
progressMonitorInterval
```
int progressMonitorInterval
```
printStatusInterval
```
int printStatusInterval
```
myHost
```
java.lang.String myHost
```
masterHost
```
java.lang.String masterHost
```
master
```
boolean master
```
termQueryTS
```
int termQueryTS
```
termQueryCounter
```
int termQueryCounter
```
workerCount
```
int workerCount
```
totalTasks
```
int totalTasks
```
totalAborts
```
int totalAborts
```
committedTSList
```
java.util.HashSet<E> committedTSList
```
abortOnStartCounter
```
java.lang.Integer abortOnStartCounter
```

Class beehive.workpool.ProgressStatus extends java.lang.Object implements Serializable
- Serialized Fields
  - abortRatio
```
float abortRatio
```
  - activeTask
```
int activeTask
```
Class beehive.workpool.ValidateResponse extends java.lang.Object implements Serializable
- Serialized Fields
  - commit
```
boolean commit
```
  - commitTS
```
long commitTS
```
  - latestSTS
```
long latestSTS
```
  - refetchSet
```
java.util.HashSet<E> refetchSet
```
  - localResponse
```
boolean localResponse
```
  - speculativeAbort
```
boolean speculativeAbort
```
  - loadVector
```
java.util.Vector<E> loadVector
```
  - conflictingTS
```
long conflictingTS
```
Class beehive.workpool.ValidationRequest extends java.lang.Object implements Serializable
- Serialized Fields
  - tid
```
java.lang.String tid
```
  - rwSet
```
RWSetInfo rwSet
```
  - startTS
```
long startTS
```
Class beehive.workpool.WorkStatus extends java.lang.Object implements Serializable
- Serialized Fields
  - status
```
StatusType status
```
  - taskList
```
java.util.Vector<E> taskList
```
  - task
```
Task task
```
  - latestSTS
```
long latestSTS
```

Serialized Form

Package beehive.server

Class beehive.server.HashtableServerImpl extends java.rmi.server.UnicastRemoteObject implements Serializable

Serialized Fields

myURL

myId

table

locationTable

cacheTable

metaDataTable

lockedObjects

changeMasterCount

statCachedCopyNumTimesUsed

statCountInvalidateCallSize

statInvalidateTime

statGetCallTime

statPutCallTime

statGetNodeForCachingTime

statGetNodesForCachingCallSize

invalidateCacheCopiesCallSize

statInvalidateCacheCopiesTime

statCountNumCacheStarts

statCountNumCachePuts

statCountNumCacheInvalidations

useCaching

log

recordStats

cacheInvalidationScheme

cacheUsageQueue

CACHE_TABLE_SIZE

CACHE_WINDOW

CACHE_CLEANUP_TARGET

numServers

servers

Class beehive.server.ResultObject extends java.lang.Object implements Serializable

Serialized Fields

status

statuscode

node

nodeId

location

metadata

Class beehive.server.ResultObjectReflection extends java.lang.Object implements Serializable

Serialized Fields

node

nodeId

status

statuscode

location

metadata

Package beehive.util

Class beehive.util.ClusterMeasures extends java.lang.Object implements Serializable

Serialized Fields

numNodes

totalEdges

internalEdges

outgoingEdges

Class beehive.util.Edge extends java.lang.Object implements Serializable

Serialized Fields

neighborId

Class beehive.util.Node extends java.lang.Object implements Serializable

Serialized Fields

nodeId

TS

neighbors

Class beehive.util.NodeData extends java.lang.Object implements Serializable

Serialized Fields

nodeId

TS

properties

Class beehive.util.NodeMetadata extends java.lang.Object implements Serializable

Serialized Fields

nodeID

masterNodeID

isMaster

cacheCopyNodes

masterCopySite

cachingInProgressFlag

numTimesUsed

lastAccessedTS