Toggle navigation
Home
long to java.util.concurrent.atomic.AtomicLong
No. of Instances - 79
No. of Commits - 46
No. of Projects - {'Lealone', 'hadoop', 'pulsar', 'optaplanner', 'camel', 'tomcat', 'jersey', 'sonarqube', 'nd4j', 'drill', 'alluxio', 'jgit', 'hbase', 'ignite', 'graylog2-server', 'presto', 'uaa', 'orientdb', 'neo4j', 'flink', 'guava', 'rapidoid'}
Hierarchy/Composition: Composition
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
Add or Remove Method invocation
this.committedSize
to
committedSize.get()
row.getKey()
to
lastKey.incrementAndGet()
value
to
value.get()
CacheBuilder.newBuilder().expireAfterWrite(expirationTimeMillis,TimeUnit.MILLISECONDS).maximumSize(20000).ticker(ticker)
to
CacheBuilder.newBuilder().expireAfterWrite(expirationTimeMillis.get(),TimeUnit.MILLISECONDS).maximumSize(20000).ticker(ticker)
minimumTimestamp
to
minimumTimestamp.get()
maximumTimestamp
to
maximumTimestamp.get()
this.writeBufferPeriodicFlushTimeoutMs
to
writeBufferPeriodicFlushTimeoutMs.get()
this.writeBufferPeriodicFlushTimerTickMs
to
writeBufferPeriodicFlushTimerTickMs.get()
writeBufferPeriodicFlushTimerTickMs
to
writeBufferPeriodicFlushTimerTickMs.get()
this.writeBufferPeriodicFlushTimeoutMs
to
writeBufferPeriodicFlushTimeoutMs.get()
this.writeBufferPeriodicFlushTimerTickMs
to
writeBufferPeriodicFlushTimerTickMs.get()
message.append("total size for store is ").append(StringUtils.TraditionalBinaryPrefix.long2String(storeSize,"",1)).append(". This selection was in queue for ").append(StringUtils.formatTimeDiff(compactionStartTime,cr.getSelectionTime())).append(", and took ").append(StringUtils.formatTimeDiff(now,compactionStartTime))
to
message.append("total size for store is ").append(StringUtils.TraditionalBinaryPrefix.long2String(storeSize.get(),"",1)).append(". This selection was in queue for ").append(StringUtils.formatTimeDiff(compactionStartTime,cr.getSelectionTime())).append(", and took ").append(StringUtils.formatTimeDiff(now,compactionStartTime))
TraditionalBinaryPrefix.long2String(storeSize,"",1)
to
TraditionalBinaryPrefix.long2String(storeSize.get(),"",1)
(float)deleted
to
deleted.floatValue()
toStringHelper(this).add("usedBytes",reservedBytes)
to
toStringHelper(this).add("usedBytes",reservedBytes.get())
numTransactionsBatchedInSync
to
numTransactionsBatchedInSync.get()
lastSentTime
to
this.lastSentTime.get()
getTimeNanos
to
getTimeNanos.get()
putTimeNanos
to
putTimeNanos.get()
removeTimeNanos
to
removeTimeNanos.get()
this.value
to
value.get()
this.lastValue
to
lastValue.get()
this.value
to
value.get()
this.lastValue
to
lastValue.get()
Other
size.get()
to
size.get()
scoreDirector.getCalculationCount()
to
scoreDirector.getCalculationCount()
syncSlots()
to
syncSlots()
System.currentTimeMillis()
to
System.currentTimeMillis()
in.readLong()
to
in.readLong()
in.readLong()
to
in.readLong()
System.currentTimeMillis()
to
System.currentTimeMillis()
Math.max(0,timeoutMs)
to
Math.max(0,timeoutMs)
Math.max(MIN_WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS,timerTickMs)
to
Math.max(MIN_WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS,timerTickMs)
getCompactionProgress().getTotalCompactingKVs()
to
getCompactionProgress().getTotalCompactingKVs()
storeFile.getReader().getTotalUncompressedBytes()
to
storeFile.getReader().getTotalUncompressedBytes()
r.getTotalUncompressedBytes()
to
r.getTotalUncompressedBytes()
r.getTotalUncompressedBytes()
to
r.getTotalUncompressedBytes()
r.getTotalUncompressedBytes()
to
r.getTotalUncompressedBytes()
getCompactionProgress().getTotalCompactingKVs()
to
getCompactionProgress().getTotalCompactingKVs()
r.length()
to
r.length()
r.length()
to
r.length()
r.length()
to
r.length()
System.nanoTime()
to
System.nanoTime()
Time.monotonicNow()
to
Time.monotonicNow()
Rename Method invocation
getKey
to
setKey
Update Class Instacne Creation
new AtomicLong(startTick)
to
new AtomicLong(startTick.get())