database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

add data size field for partition cache (#6026)

Browse Source 
Co-authored-by: wangxixu <wangxixu@xiaomi.com>
This commit is contained in:
xinghuayu007
2021-06-18 11:40:00 +08:00
committed by GitHub
parent 1999a0c26b
commit bff6ede94e
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-core/src/main/java/org/apache/doris/qe/cache/RowBatchBuilder.java vendored
View File

@ -167,13 +167,17 @@ public class RowBatchBuilder {
Long key = entry.getKey();
PartitionRange.PartitionSingle partition = cachePartMap.get(key);
partitionRowList = entry.getValue();
int data_size = 0;
for (byte[] buf : partitionRowList) {
data_size += buf.length;
}
updateRequest = updateRequest.toBuilder()
.addValues(InternalService.PCacheValue.newBuilder()
.setParam(InternalService.PCacheParam.newBuilder()
.setPartitionKey(key)
.setLastVersion(partition.getPartition().getVisibleVersion())
.setLastVersionTime(partition.getPartition().getVisibleVersionTime())
.build()).addAllRows(
.build()).setDataSize(dataSize).addAllRows(
partitionRowList.stream().map(row -> ByteString.copyFrom(row))
.collect(Collectors.toList()))).build();
}