@@ -78,10 +78,9 @@ class TColumnChunkRestoreInfo {
78
78
i.second .GetBlobDataVerified ().size ());
79
79
std::vector<NArrow::NAccessor::TDeserializeChunkedArray::TChunk> chunks = { NArrow::NAccessor::TDeserializeChunkedArray::TChunk (
80
80
GetRecordsCount (), i.second .GetBlobDataVerified ()) };
81
- // const ui32 filledRecordsCount = PartialArray->GetHeader().GetColumnStats().GetColumnRecordsCount(i.second.GetColumnIdx());
82
81
const std::shared_ptr<NArrow::NAccessor::IChunkedArray> arrOriginal =
83
82
deserialize
84
- ? columnLoader->ApplyVerified (i.second .GetBlobDataVerified (), GetRecordsCount ()/* , filledRecordsCount */ )
83
+ ? columnLoader->ApplyVerified (i.second .GetBlobDataVerified (), GetRecordsCount ())
85
84
: std::make_shared<NArrow::NAccessor::TDeserializeChunkedArray>(GetRecordsCount (), columnLoader, std::move (chunks), true );
86
85
if (applyFilter) {
87
86
PartialArray->AddColumn (i.first , applyFilter->Apply (arrOriginal));
@@ -122,8 +121,8 @@ class TColumnChunkRestoreInfo {
122
121
AFL_VERIFY (!PartialArray);
123
122
HeaderRange = std::nullopt;
124
123
PartialArray = NArrow::NAccessor::NSubColumns::TConstructor::BuildPartialReader (blob, ChunkExternalInfo).DetachResult ();
125
- // AFL_ERROR(NKikimrServices::TX_COLUMNSHARD_SCAN)("columns", PartialArray->GetHeader().GetColumnStats().DebugJson().GetStringRobust())(
126
- // "others", PartialArray->GetHeader().GetOtherStats().DebugJson().GetStringRobust());
124
+ // AFL_ERROR(NKikimrServices::TX_COLUMNSHARD_SCAN)("columns", PartialArray->GetHeader().GetColumnStats().DebugJson().GetStringRobust())(
125
+ // "others", PartialArray->GetHeader().GetOtherStats().DebugJson().GetStringRobust());
127
126
}
128
127
129
128
void InitPartialReader (const std::shared_ptr<NArrow::NAccessor::IChunkedArray>& accessor) {
0 commit comments