github-actions[bot] commented on code in PR #32873:
URL: https://github.com/apache/doris/pull/32873#discussion_r1556789383
##########
be/src/vec/exec/format/parquet/parquet_column_convert.cpp:
##########
@@ -20,67 +20,289 @@
#include <cctz/time_zone.h>
#include "vec/columns/column_nullable.h"
-namespace doris::vectorized {
-namespace ParquetConvert {
+namespace doris::vectorized::parquet {
const cctz::time_zone ConvertParams::utc0 = cctz::utc_time_zone();
-ColumnPtr get_column(tparquet::Type::type parquet_physical_type, PrimitiveType
show_type,
- ColumnPtr& doris_column, DataTypePtr& doris_type, bool*
need_convert) {
- ColumnPtr ans_column = doris_column;
- DataTypePtr tmp_data_type;
-
- switch (parquet_physical_type) {
- case tparquet::Type::type::BOOLEAN:
- tmp_data_type = std::make_shared<DataTypeUInt8>();
- break;
- case tparquet::Type::type::INT32:
- tmp_data_type = std::make_shared<DataTypeInt32>();
- break;
- case tparquet::Type::type::INT64:
- tmp_data_type = std::make_shared<DataTypeInt64>();
- break;
- case tparquet::Type::type::FLOAT:
- tmp_data_type = std::make_shared<DataTypeFloat32>();
- break;
- case tparquet::Type::type::DOUBLE:
- tmp_data_type = std::make_shared<DataTypeFloat64>();
- break;
- case tparquet::Type::type::BYTE_ARRAY:
- case tparquet::Type::type::FIXED_LEN_BYTE_ARRAY:
- tmp_data_type = std::make_shared<DataTypeString>();
- break;
- case tparquet::Type::type::INT96:
- tmp_data_type = std::make_shared<DataTypeInt8>();
- break;
+#define FOR_LOGICAL_DECIMAL_TYPES(M) \
+ M(TYPE_DECIMALV2) \
+ M(TYPE_DECIMAL32) \
+ M(TYPE_DECIMAL64) \
+ M(TYPE_DECIMAL128I)
+
+bool PhysicalToLogicalConverter::is_parquet_native_type(PrimitiveType type) {
+ switch (type) {
+ case TYPE_BOOLEAN:
+ case TYPE_INT:
+ case TYPE_BIGINT:
+ case TYPE_FLOAT:
+ case TYPE_DOUBLE:
+ case TYPE_STRING:
+ case TYPE_CHAR:
+ case TYPE_VARCHAR:
+ return true;
+ default:
+ return false;
+ }
+}
+
+bool PhysicalToLogicalConverter::is_decimal_type(doris::PrimitiveType type) {
+ switch (type) {
+ case TYPE_DECIMAL32:
+ case TYPE_DECIMAL64:
+ case TYPE_DECIMAL128I:
+ case TYPE_DECIMALV2:
+ return true;
+ default:
+ return false;
+ }
+}
+
+ColumnPtr PhysicalToLogicalConverter::get_physical_column(tparquet::Type::type
src_physical_type,
+ TypeDescriptor
src_logical_type,
+ ColumnPtr&
dst_logical_column,
+ const DataTypePtr&
dst_logical_type,
+ bool is_dict_filter)
{
+ if (is_dict_filter) {
+ src_physical_type = tparquet::Type::INT32;
+ src_logical_type = TypeDescriptor(PrimitiveType::TYPE_INT);
+ }
+ if (is_consistent() && _logical_converter->is_consistent()) {
+ if (_cached_src_physical_type == nullptr) {
+ _cached_src_physical_type =
DataTypeFactory::instance().create_data_type(
+ src_logical_type, dst_logical_type->is_nullable());
+ }
+ return dst_logical_column;
}
- if (tmp_data_type->get_type_id() ==
remove_nullable(doris_type)->get_type_id()) {
- if (tmp_data_type->get_type_id() == TypeIndex::String &&
- (show_type == PrimitiveType::TYPE_DECIMAL32 ||
- show_type == PrimitiveType::TYPE_DECIMAL64 ||
- show_type == PrimitiveType::TYPE_DECIMALV2 ||
- show_type == PrimitiveType::TYPE_DECIMAL128I)) {
- *need_convert = true;
- ans_column = tmp_data_type->create_column();
+ if (_cached_src_physical_column == nullptr) {
+ switch (src_physical_type) {
+ case tparquet::Type::type::BOOLEAN:
+ _cached_src_physical_type = std::make_shared<DataTypeUInt8>();
+ break;
+ case tparquet::Type::type::INT32:
+ _cached_src_physical_type = std::make_shared<DataTypeInt32>();
+ break;
+ case tparquet::Type::type::INT64:
+ _cached_src_physical_type = std::make_shared<DataTypeInt64>();
+ break;
+ case tparquet::Type::type::FLOAT:
+ _cached_src_physical_type = std::make_shared<DataTypeFloat32>();
+ break;
+ case tparquet::Type::type::DOUBLE:
+ _cached_src_physical_type = std::make_shared<DataTypeFloat64>();
+ break;
+ case tparquet::Type::type::BYTE_ARRAY:
+ _cached_src_physical_type = std::make_shared<DataTypeString>();
+ break;
+ case tparquet::Type::type::FIXED_LEN_BYTE_ARRAY:
+ _cached_src_physical_type = std::make_shared<DataTypeUInt8>();
+ break;
+ case tparquet::Type::type::INT96:
+ _cached_src_physical_type = std::make_shared<DataTypeInt8>();
+ break;
+ }
+ _cached_src_physical_column =
_cached_src_physical_type->create_column();
+ if (dst_logical_type->is_nullable()) {
+ _cached_src_physical_type =
make_nullable(_cached_src_physical_type);
+ }
+ }
+ // remove the old cached data
+ _cached_src_physical_column->assume_mutable()->clear();
+ if (is_consistent()) {
+ if (dst_logical_type->is_nullable()) {
+ auto doris_nullable_column = const_cast<ColumnNullable*>(
+ static_cast<const
ColumnNullable*>(dst_logical_column.get()));
+ _src_logical_column = ColumnNullable::create(
+ _cached_src_physical_column,
doris_nullable_column->get_null_map_column_ptr());
} else {
- *need_convert = false;
+ _src_logical_column = _cached_src_physical_column;
}
} else {
- ans_column = tmp_data_type->create_column();
- *need_convert = true;
+ _src_logical_column = _logical_converter->get_column(src_logical_type,
dst_logical_column,
+ dst_logical_type);
}
- if (*need_convert && doris_type->is_nullable()) {
+ if (dst_logical_type->is_nullable()) {
// In order to share null map between parquet converted src column and
dst column to avoid copying. It is very tricky that will
// call mutable function
`doris_nullable_column->get_null_map_column_ptr()` which will set
`_need_update_has_null = true`.
// Because some operations such as agg will call `has_null()` to set
`_need_update_has_null = false`.
- auto doris_nullable_column =
- const_cast<ColumnNullable*>(static_cast<const
ColumnNullable*>(doris_column.get()));
- ans_column = ColumnNullable::create(ans_column,
-
doris_nullable_column->get_null_map_column_ptr());
+ auto doris_nullable_column = const_cast<ColumnNullable*>(
+ static_cast<const ColumnNullable*>(dst_logical_column.get()));
+ return ColumnNullable::create(_cached_src_physical_column,
+
doris_nullable_column->get_null_map_column_ptr());
+ }
+
+ return _cached_src_physical_column;
+}
+
+static void get_decimal_converter(FieldSchema* field_schema, TypeDescriptor
src_logical_type,
Review Comment:
warning: function 'get_decimal_converter' exceeds recommended
size/complexity thresholds [readability-function-size]
```cpp
static void get_decimal_converter(FieldSchema* field_schema, TypeDescriptor
src_logical_type,
^
```
<details>
<summary>Additional context</summary>
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:137:** 105 lines
including whitespace and comments (threshold 80)
```cpp
static void get_decimal_converter(FieldSchema* field_schema, TypeDescriptor
src_logical_type,
^
```
</details>
##########
be/src/vec/exec/format/parquet/parquet_column_convert.cpp:
##########
@@ -20,67 +20,289 @@
#include <cctz/time_zone.h>
#include "vec/columns/column_nullable.h"
-namespace doris::vectorized {
-namespace ParquetConvert {
+namespace doris::vectorized::parquet {
const cctz::time_zone ConvertParams::utc0 = cctz::utc_time_zone();
-ColumnPtr get_column(tparquet::Type::type parquet_physical_type, PrimitiveType
show_type,
- ColumnPtr& doris_column, DataTypePtr& doris_type, bool*
need_convert) {
- ColumnPtr ans_column = doris_column;
- DataTypePtr tmp_data_type;
-
- switch (parquet_physical_type) {
- case tparquet::Type::type::BOOLEAN:
- tmp_data_type = std::make_shared<DataTypeUInt8>();
- break;
- case tparquet::Type::type::INT32:
- tmp_data_type = std::make_shared<DataTypeInt32>();
- break;
- case tparquet::Type::type::INT64:
- tmp_data_type = std::make_shared<DataTypeInt64>();
- break;
- case tparquet::Type::type::FLOAT:
- tmp_data_type = std::make_shared<DataTypeFloat32>();
- break;
- case tparquet::Type::type::DOUBLE:
- tmp_data_type = std::make_shared<DataTypeFloat64>();
- break;
- case tparquet::Type::type::BYTE_ARRAY:
- case tparquet::Type::type::FIXED_LEN_BYTE_ARRAY:
- tmp_data_type = std::make_shared<DataTypeString>();
- break;
- case tparquet::Type::type::INT96:
- tmp_data_type = std::make_shared<DataTypeInt8>();
- break;
+#define FOR_LOGICAL_DECIMAL_TYPES(M) \
+ M(TYPE_DECIMALV2) \
+ M(TYPE_DECIMAL32) \
+ M(TYPE_DECIMAL64) \
+ M(TYPE_DECIMAL128I)
+
+bool PhysicalToLogicalConverter::is_parquet_native_type(PrimitiveType type) {
+ switch (type) {
+ case TYPE_BOOLEAN:
+ case TYPE_INT:
+ case TYPE_BIGINT:
+ case TYPE_FLOAT:
+ case TYPE_DOUBLE:
+ case TYPE_STRING:
+ case TYPE_CHAR:
+ case TYPE_VARCHAR:
+ return true;
+ default:
+ return false;
+ }
+}
+
+bool PhysicalToLogicalConverter::is_decimal_type(doris::PrimitiveType type) {
+ switch (type) {
+ case TYPE_DECIMAL32:
+ case TYPE_DECIMAL64:
+ case TYPE_DECIMAL128I:
+ case TYPE_DECIMALV2:
+ return true;
+ default:
+ return false;
+ }
+}
+
+ColumnPtr PhysicalToLogicalConverter::get_physical_column(tparquet::Type::type
src_physical_type,
+ TypeDescriptor
src_logical_type,
+ ColumnPtr&
dst_logical_column,
+ const DataTypePtr&
dst_logical_type,
+ bool is_dict_filter)
{
+ if (is_dict_filter) {
+ src_physical_type = tparquet::Type::INT32;
+ src_logical_type = TypeDescriptor(PrimitiveType::TYPE_INT);
+ }
+ if (is_consistent() && _logical_converter->is_consistent()) {
+ if (_cached_src_physical_type == nullptr) {
+ _cached_src_physical_type =
DataTypeFactory::instance().create_data_type(
+ src_logical_type, dst_logical_type->is_nullable());
+ }
+ return dst_logical_column;
}
- if (tmp_data_type->get_type_id() ==
remove_nullable(doris_type)->get_type_id()) {
- if (tmp_data_type->get_type_id() == TypeIndex::String &&
- (show_type == PrimitiveType::TYPE_DECIMAL32 ||
- show_type == PrimitiveType::TYPE_DECIMAL64 ||
- show_type == PrimitiveType::TYPE_DECIMALV2 ||
- show_type == PrimitiveType::TYPE_DECIMAL128I)) {
- *need_convert = true;
- ans_column = tmp_data_type->create_column();
+ if (_cached_src_physical_column == nullptr) {
+ switch (src_physical_type) {
+ case tparquet::Type::type::BOOLEAN:
+ _cached_src_physical_type = std::make_shared<DataTypeUInt8>();
+ break;
+ case tparquet::Type::type::INT32:
+ _cached_src_physical_type = std::make_shared<DataTypeInt32>();
+ break;
+ case tparquet::Type::type::INT64:
+ _cached_src_physical_type = std::make_shared<DataTypeInt64>();
+ break;
+ case tparquet::Type::type::FLOAT:
+ _cached_src_physical_type = std::make_shared<DataTypeFloat32>();
+ break;
+ case tparquet::Type::type::DOUBLE:
+ _cached_src_physical_type = std::make_shared<DataTypeFloat64>();
+ break;
+ case tparquet::Type::type::BYTE_ARRAY:
+ _cached_src_physical_type = std::make_shared<DataTypeString>();
+ break;
+ case tparquet::Type::type::FIXED_LEN_BYTE_ARRAY:
+ _cached_src_physical_type = std::make_shared<DataTypeUInt8>();
+ break;
+ case tparquet::Type::type::INT96:
+ _cached_src_physical_type = std::make_shared<DataTypeInt8>();
+ break;
+ }
+ _cached_src_physical_column =
_cached_src_physical_type->create_column();
+ if (dst_logical_type->is_nullable()) {
+ _cached_src_physical_type =
make_nullable(_cached_src_physical_type);
+ }
+ }
+ // remove the old cached data
+ _cached_src_physical_column->assume_mutable()->clear();
+ if (is_consistent()) {
+ if (dst_logical_type->is_nullable()) {
+ auto doris_nullable_column = const_cast<ColumnNullable*>(
+ static_cast<const
ColumnNullable*>(dst_logical_column.get()));
+ _src_logical_column = ColumnNullable::create(
+ _cached_src_physical_column,
doris_nullable_column->get_null_map_column_ptr());
} else {
- *need_convert = false;
+ _src_logical_column = _cached_src_physical_column;
}
} else {
- ans_column = tmp_data_type->create_column();
- *need_convert = true;
+ _src_logical_column = _logical_converter->get_column(src_logical_type,
dst_logical_column,
+ dst_logical_type);
}
- if (*need_convert && doris_type->is_nullable()) {
+ if (dst_logical_type->is_nullable()) {
// In order to share null map between parquet converted src column and
dst column to avoid copying. It is very tricky that will
// call mutable function
`doris_nullable_column->get_null_map_column_ptr()` which will set
`_need_update_has_null = true`.
// Because some operations such as agg will call `has_null()` to set
`_need_update_has_null = false`.
- auto doris_nullable_column =
- const_cast<ColumnNullable*>(static_cast<const
ColumnNullable*>(doris_column.get()));
- ans_column = ColumnNullable::create(ans_column,
-
doris_nullable_column->get_null_map_column_ptr());
+ auto doris_nullable_column = const_cast<ColumnNullable*>(
+ static_cast<const ColumnNullable*>(dst_logical_column.get()));
+ return ColumnNullable::create(_cached_src_physical_column,
+
doris_nullable_column->get_null_map_column_ptr());
+ }
+
+ return _cached_src_physical_column;
+}
+
+static void get_decimal_converter(FieldSchema* field_schema, TypeDescriptor
src_logical_type,
Review Comment:
warning: function 'get_decimal_converter' has cognitive complexity of 131
(threshold 50) [readability-function-cognitive-complexity]
```cpp
static void get_decimal_converter(FieldSchema* field_schema, TypeDescriptor
src_logical_type,
^
```
<details>
<summary>Additional context</summary>
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:142:** +1,
including nesting penalty of 0, nesting level increased to 1
```cpp
if (is_decimal(remove_nullable(dst_logical_type))) {
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:151:** +1,
including nesting penalty of 0, nesting level increased to 1
```cpp
if (src_physical_type == tparquet::Type::FIXED_LEN_BYTE_ARRAY) {
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:152:** +2,
including nesting penalty of 1, nesting level increased to 2
```cpp
switch (src_logical_primitive) {
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:173:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:178:** +1,
nesting level increased to 1
```cpp
} else if (src_physical_type == tparquet::Type::BYTE_ARRAY) {
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:179:** +2,
including nesting penalty of 1, nesting level increased to 2
```cpp
switch (src_logical_primitive) {
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:197:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:202:** +1,
nesting level increased to 1
```cpp
} else if (src_physical_type == tparquet::Type::INT32 ||
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:204:** +2,
including nesting penalty of 1, nesting level increased to 2
```cpp
switch (src_logical_primitive) {
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +3,
including nesting penalty of 2, nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 3
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +4,
including nesting penalty of 3, nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:237:** +1,
nesting level increased to 4
```cpp
FOR_LOGICAL_DECIMAL_TYPES(DISPATCH)
^
```
**be/src/vec/exec/format/parquet/parquet_column_convert.cpp:242:** +1,
nesting level increased to 1
```cpp
} else {
^
```
</details>
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
