Skip to content

Commit

Permalink
add rowIsDeletedProjected when !includeAcidColumns
Browse files Browse the repository at this point in the history
  • Loading branch information
kasakrisz committed May 12, 2021
1 parent 523aa40 commit d639aec
Showing 1 changed file with 7 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -914,6 +914,13 @@ public boolean next(NullWritable key, VectorizedRowBatch value) throws IOExcepti
value.selected = vectorizedRowBatchBase.selected;
value.selectedInUse = vectorizedRowBatchBase.selectedInUse;
copyFromBase(value);

if (rowIsDeletedProjected) {
Arrays.fill(rowIsDeletedVector.vector, 0);
int ix = rbCtx.findVirtualColumnNum(VirtualColumn.ROWISDELETED);
value.cols[ix] = rowIsDeletedVector;
}

progress = baseReader.getProgress();
return true;
}
Expand Down

0 comments on commit d639aec

Please sign in to comment.