Skip to content

Commit 70fba7c

Browse files
authored
Merge pull request #1076 from Altinity/bugfix/antalya-25.8/filimonov_wipes_my_snot
25.8 Antalya: Fixes for #1069
2 parents 62d227b + a732f75 commit 70fba7c

File tree

2 files changed

+19
-10
lines changed

2 files changed

+19
-10
lines changed

src/Storages/ObjectStorage/DataLakes/IDataLakeMetadata.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -141,9 +141,9 @@ void DataFileMetaInfo::serialize(WriteBuffer & out) const
141141
size_t field_mask = 0;
142142
if (column.second.rows_count.has_value())
143143
field_mask |= FIELD_MASK_ROWS;
144-
if (column.second.rows_count.has_value())
144+
if (column.second.nulls_count.has_value())
145145
field_mask |= FIELD_MASK_NULLS;
146-
if (column.second.rows_count.has_value())
146+
if (column.second.hyperrectangle.has_value())
147147
field_mask |= FIELD_MASK_RECT;
148148
writeIntBinary(field_mask, out);
149149

src/Storages/ObjectStorage/DataLakes/Iceberg/ManifestFile.h

Lines changed: 17 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,23 @@
11
#pragma once
22

33
#include "config.h"
4+
#include <Core/Range.h>
5+
#include <Core/Types.h>
6+
7+
#include <optional>
8+
9+
namespace DB::Iceberg
10+
{
11+
12+
struct ColumnInfo
13+
{
14+
std::optional<Int64> rows_count;
15+
std::optional<Int64> bytes_size;
16+
std::optional<Int64> nulls_count;
17+
std::optional<DB::Range> hyperrectangle;
18+
};
19+
20+
}
421

522
#if USE_AVRO
623

@@ -38,14 +55,6 @@ enum class ManifestFileContentType
3855

3956
String FileContentTypeToString(FileContentType type);
4057

41-
struct ColumnInfo
42-
{
43-
std::optional<Int64> rows_count;
44-
std::optional<Int64> bytes_size;
45-
std::optional<Int64> nulls_count;
46-
std::optional<DB::Range> hyperrectangle;
47-
};
48-
4958
struct PartitionSpecsEntry
5059
{
5160
Int32 source_id;

0 commit comments

Comments
 (0)