Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
ivanmorozov333 committed Jan 28, 2025
1 parent 7524918 commit 275bac4
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 21 deletions.
16 changes: 0 additions & 16 deletions ydb/core/tx/columnshard/engines/scheme/column/info.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3,22 +3,6 @@

namespace NKikimr::NOlap {

NArrow::NTransformation::ITransformer::TPtr TSimpleColumnInfo::GetSaveTransformer() const {
NArrow::NTransformation::ITransformer::TPtr transformer;
if (DictionaryEncoding) {
transformer = DictionaryEncoding->BuildEncoder();
}
return transformer;
}

NArrow::NTransformation::ITransformer::TPtr TSimpleColumnInfo::GetLoadTransformer() const {
NArrow::NTransformation::ITransformer::TPtr transformer;
if (DictionaryEncoding) {
transformer = DictionaryEncoding->BuildDecoder();
}
return transformer;
}

TConclusionStatus TSimpleColumnInfo::DeserializeFromProto(const NKikimrSchemeOp::TOlapColumnDescription& columnInfo) {
AFL_VERIFY(columnInfo.GetId() == ColumnId);
if (columnInfo.HasSerializer()) {
Expand Down
6 changes: 1 addition & 5 deletions ydb/core/tx/columnshard/engines/scheme/column/info.h
Original file line number Diff line number Diff line change
Expand Up @@ -30,19 +30,16 @@ class TSimpleColumnInfo {
YDB_READONLY(bool, IsSorted, false);
YDB_READONLY(bool, IsNullable, false);
YDB_READONLY_DEF(TColumnDefaultScalarValue, DefaultValue);
std::optional<NArrow::NDictionary::TEncodingSettings> DictionaryEncoding;
std::shared_ptr<TColumnLoader> Loader;
NArrow::NTransformation::ITransformer::TPtr GetLoadTransformer() const;

public:
TSimpleColumnInfo(const ui32 columnId, const std::shared_ptr<arrow::Field>& arrowField,
const NArrow::NSerialization::TSerializerContainer& serializer, const bool needMinMax, const bool isSorted, const bool isNullable,
const std::shared_ptr<arrow::Scalar>& defaultValue, const std::optional<ui32>& pkColumnIndex);

TColumnSaver GetColumnSaver() const {
NArrow::NTransformation::ITransformer::TPtr transformer = GetSaveTransformer();
AFL_VERIFY(Serializer);
return TColumnSaver(transformer, Serializer);
return TColumnSaver(Serializer);
}

std::vector<std::shared_ptr<IPortionDataChunk>> ActualizeColumnData(
Expand All @@ -56,7 +53,6 @@ class TSimpleColumnInfo {
return sb;
}

NArrow::NTransformation::ITransformer::TPtr GetSaveTransformer() const;
TConclusionStatus DeserializeFromProto(const NKikimrSchemeOp::TOlapColumnDescription& columnInfo);

const std::shared_ptr<TColumnLoader>& GetLoader() const {
Expand Down

0 comments on commit 275bac4

Please sign in to comment.