Skip to content

Commit 8290aa5

Browse files
fix build
1 parent 7b87aad commit 8290aa5

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ydb/core/tx/columnshard/engines/changes/indexation.cpp

+3-3
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
#include <ydb/core/protos/counters_columnshard.pb.h>
44
#include <ydb/core/tx/columnshard/columnshard_impl.h>
55
#include <ydb/core/tx/columnshard/blobs_action/blob_manager_db.h>
6-
#include <ydb/core/formats/arrow/serializer/arrow.h>
6+
#include <ydb/core/formats/arrow/serializer/native.h>
77

88
namespace NKikimr::NOlap {
99

@@ -117,9 +117,9 @@ TConclusionStatus TInsertColumnEngineChanges::DoConstructBlobs(TConstructionCont
117117
continue;
118118
}
119119
if (b->num_rows() < 100) {
120-
SaverContext.SetExternalSerializer(NArrow::NSerialization::TSerializerContainer(std::make_shared<NArrow::NSerialization::TArrowSerializer>(arrow::Compression::type::UNCOMPRESSED)));
120+
SaverContext.SetExternalSerializer(NArrow::NSerialization::TSerializerContainer(std::make_shared<NArrow::NSerialization::TNativeSerializer>(arrow::Compression::type::UNCOMPRESSED)));
121121
} else {
122-
SaverContext.SetExternalSerializer(NArrow::NSerialization::TSerializerContainer(std::make_shared<NArrow::NSerialization::TArrowSerializer>(arrow::Compression::type::LZ4_FRAME)));
122+
SaverContext.SetExternalSerializer(NArrow::NSerialization::TSerializerContainer(std::make_shared<NArrow::NSerialization::TNativeSerializer>(arrow::Compression::type::LZ4_FRAME)));
123123
}
124124
auto portions = MakeAppendedPortions(b, pathId, maxSnapshot, nullptr, context);
125125
Y_ABORT_UNLESS(portions.size());

0 commit comments

Comments
 (0)