File tree 1 file changed +6
-3
lines changed
1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -329,14 +329,15 @@ void GroupConcatAg::initialize()
329
329
fRowGroup .resetRowGroup (0 );
330
330
fRowGroup .initRow (&fRow );
331
331
fRowGroup .getRow (0 , &fRow );
332
+ fMemSize = fRowGroup .getSizeWithStrings (1 );
332
333
}
333
334
else
334
335
{
335
336
fGroupConcat ->fRowGroup .initRow (&fRow , true );
336
337
fData .reset (new uint8_t [fRow .getSize ()]);
337
338
fRow .setData (rowgroup::Row::Pointer (fData .get ()));
339
+ fMemSize = fRow .getSize ();
338
340
}
339
- fMemSize = fRowGroup .getSizeWithStrings (1 );
340
341
}
341
342
342
343
void GroupConcatAg::processRow (const rowgroup::Row& inRow)
@@ -1055,7 +1056,7 @@ void GroupConcatOrderBy::deserialize(messageqcpp::ByteStream& bs)
1055
1056
1056
1057
void GroupConcatOrderBy::createNewRGData ()
1057
1058
{
1058
- auto newSize = fRowGroup .getDataSize (fRowsPerRG );
1059
+ auto newSize = fRowGroup .getSizeWithStrings (fRowsPerRG );
1059
1060
1060
1061
fMemSize += newSize;
1061
1062
@@ -1069,7 +1070,9 @@ void GroupConcatOrderBy::createNewRGData()
1069
1070
1070
1071
rowgroup::RGDataSizeType GroupConcatOrderBy::getDataSize () const
1071
1072
{
1072
- return fMemSize ;
1073
+ return fMemSize
1074
+ + fOrderByQueue ->capacity () * sizeof (OrderByRow)
1075
+ + fDistinctMap ->size () * 32 /* TODO: speculative unordered_map memory consumption per item, replace it with counting allocator */ ;
1073
1076
}
1074
1077
1075
1078
void GroupConcatOrderBy::processRow (const rowgroup::Row& row)
You can’t perform that action at this time.
0 commit comments