-
Notifications
You must be signed in to change notification settings - Fork 422
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
NODE-2622 Delete old data #3912
Conversation
- setIncreaseParallelism & setMaxBackgroundJobs: 4 -> 5.
This reverts commit 2697ae1.
- default parallelism; - fixed tests.
val updateAtKeys = new ArrayBuffer[Key[BalanceNode]]() | ||
|
||
val changedKeyPrefix = KeyTags.ChangedWavesBalances.prefixBytes | ||
val changedFromKey = Keys.changedWavesBalances(fromInclusive) // Doesn't matter, we need this only to parse |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
what does this comment mean?
changedFromKey
is used not only for parsing but also in iterateOverWithSeek
as "seek" parameter
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It means, fromInclusive
doesn't affect the parsing result. Changed the comment to make it clear.
import java.util | ||
import java.util.concurrent.{AbstractExecutorService, TimeUnit} | ||
|
||
object RunNowExecutorService extends AbstractExecutorService { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is this not the same as MoreExecutors.newDirectExecutorService()
?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Fixed
- maxWriteBufferNumber in default CF: 2 -> 3.
- maxWriteBufferNumber in default CF: 3 -> 4.
- setIncreaseParallelism: 4 -> 8; - maxBackgroundJobs removed.
- setMaxSubcompactions removed.
…ould be calculated)
- setIncreaseParallelism: 6 -> 7.
A new functionality for deletion of old data. It doesn't affect the main functionality of NODE.
Enabling this funcitonality starts a background cleanup and affects:
GET /addresses/balance/$addr/$confirmations
- confirmations should be <= 1000 to get a guaranteed result.GET /addresses/balance
POST /addresses/balance
GET /assets/$asset/distribution/$height/limit/$limit
GET /debug/balances/history/$addr
GET /debug/stateWaves/$height
A
- WAVES balance history for addressAA
- Asset balance history for addressChanges:
waves.db.cleanup-interval
. See more information in the config;Data
keys containAddressId
instead ofPublicKeyHash
;Score
,BlockTransactionsFee
,BlockReward
,WavesAmount
,HitSource
,BloomFilterChecksum
;ChangedWavesBalances
andLastCleanupHeight
to support the new functionality;Exporter
now is stack-safe;Explorer
compatibility with version-1.5.x and recent changes;node-it
tests;