@@ -71,6 +71,7 @@ class TPathFieldsInfo {
71
71
: ResultSchema(resultSchema)
72
72
, FullColumnsCount(ResultSchema->GetIndexInfo ().GetColumnIds(false ).size())
73
73
{
74
+ AFL_VERIFY (FullColumnsCount);
74
75
}
75
76
76
77
bool IsFinished () const {
@@ -83,6 +84,7 @@ class TPathFieldsInfo {
83
84
}
84
85
85
86
void Finish () {
87
+ AFL_VERIFY (UsageColumnIds.size ());
86
88
AFL_VERIFY (!Finished);
87
89
Finished = true ;
88
90
if (UsageColumnIds.size () == FullColumnsCount) {
@@ -97,7 +99,7 @@ class TPathFieldsInfo {
97
99
return UsageColumnIds;
98
100
}
99
101
100
- void AddChunkInfo (const TInsertedData& data, TConstructionContext& context) {
102
+ void AddChunkInfo (const TInsertedData& data, const TConstructionContext& context) {
101
103
AFL_VERIFY (!Finished);
102
104
if (UsageColumnIds.size () == FullColumnsCount) {
103
105
return ;
@@ -142,7 +144,7 @@ class TPathData {
142
144
return result;
143
145
}
144
146
145
- void AddChunkInfo (const NOlap::TInsertedData& data, TConstructionContext& context) {
147
+ void AddChunkInfo (const NOlap::TInsertedData& data, const TConstructionContext& context) {
146
148
ColumnsInfo.AddChunkInfo (data, context);
147
149
}
148
150
@@ -191,6 +193,7 @@ class TPathesData {
191
193
if (it == Data.end ()) {
192
194
it = Data.emplace (inserted.PathId , TPathData (shardingFilterCommit, ResultSchema)).first ;
193
195
}
196
+ it->second .AddChunkInfo (inserted, context);
194
197
it->second .AddShardingInfo (shardingFilterCommit);
195
198
}
196
199
0 commit comments