DomGarguilo commented on a change in pull request #166:
URL: https://github.com/apache/accumulo-testing/pull/166#discussion_r749645805
##########
File path:
src/main/java/org/apache/accumulo/testing/continuous/ContinuousIngest.java
##########
@@ -175,19 +191,47 @@ public static void main(String[] args) throws Exception {
// generate subsequent sets of nodes that link to previous set of nodes
for (int depth = 1; depth < maxDepth; depth++) {
+
+ // random chance that the entries will be deleted
+ boolean deletePrevious = deletesEnabled && r.nextInt(100) <
deleteProbability;
+
+ // stack to hold mutations. stack ensures they are deleted in
reverse order
+ Stack<Mutation> mutationStack = new Stack<>();
+
for (int index = 0; index < flushInterval; index++) {
long rowLong = genLong(rowMin, rowMax, r);
byte[] prevRow = genRow(prevRows[index]);
prevRows[index] = rowLong;
- Mutation m = genMutation(rowLong, r.nextInt(maxColF),
r.nextInt(maxColQ), cv,
- ingestInstanceId, count, prevRow, checksum);
+ int cfInt = r.nextInt(maxColF);
+ int cqInt = r.nextInt(maxColQ);
+ Mutation m = genMutation(rowLong, cfInt, cqInt, cv,
ingestInstanceId, count, prevRow,
+ checksum);
count++;
bw.addMutation(m);
+
+ // add a new delete mutation to the stack when applicable
+ if (deletePrevious) {
+ Mutation mutation = new Mutation(genRow(rowLong));
+ mutation.putDelete(genCol(cfInt), genCol(cqInt), cv);
+ mutationStack.add(mutation);
+ }
}
lastFlushTime = flush(bw, count, flushInterval, lastFlushTime);
if (count >= numEntries)
break out;
+
+ // delete last set of entries in reverse order
+ if (deletePrevious) {
+ log.info("Deleting previous set of entries");
+ while (!mutationStack.empty()) {
+ Mutation m = mutationStack.pop();
+ count--;
+ bw.addMutation(m);
Review comment:
I attempted to make these changes in d23b584.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
