Merge pull request ClickHouse#80050 from scanhex12/impore_geo_parquets

alexey-milovidov · web-flow · commit b884cb9da219 · 2025-05-11T22:24:37.000+02:00
Improve geo parquet
diff --git a/src/Core/FormatFactorySettings.h b/src/Core/FormatFactorySettings.h
@@ -1316,6 +1316,10 @@ Set the quoting style for identifiers in SHOW CREATE query
 Limits the size of the blocks formed during data parsing in input formats in bytes. Used in row based input formats when block is formed on ClickHouse side.
 0 means no limit in bytes.
 )", 0) \
+    DECLARE(Bool, input_format_parquet_allow_geoparquet_parser, true, R"(
+Use geo column parser to convert Array(UInt8) into Point/Linestring/Polygon/MultiLineString/MultiPolygon types
+)", 0) \
+
 
 // End of FORMAT_FACTORY_SETTINGS
 
diff --git a/src/Core/SettingsChangesHistory.cpp b/src/Core/SettingsChangesHistory.cpp
@@ -100,6 +100,7 @@ const VersionToSettingsChangesMap & getSettingsChangesHistory()
             {"allow_experimental_database_hms_catalog", false, false, "Allow experimental database engine DataLakeCatalog with catalog_type = 'hive'"},
             {"compile_expressions", false, true, "We believe that the LLVM infrastructure behind the JIT compiler is stable enough to enable this setting by default."},
             {"use_legacy_to_time", false, false, "New setting. Allows for user to use the old function logic for toTime, which works as toTimeWithFixedDate."},
+            {"input_format_parquet_allow_geoparquet_parser", false, true, "A new setting to use geo columns in parquet file"},
         });
         addSettingsChanges(settings_changes_history, "25.4",
         {
diff --git a/src/Formats/FormatFactory.cpp b/src/Formats/FormatFactory.cpp
@@ -214,6 +214,7 @@ FormatSettings getFormatSettings(const ContextPtr & context, const Settings & se
     format_settings.parquet.bloom_filter_flush_threshold_bytes = settings[Setting::output_format_parquet_bloom_filter_flush_threshold_bytes];
     format_settings.parquet.local_read_min_bytes_for_seek = settings[Setting::input_format_parquet_local_file_min_bytes_for_seek];
     format_settings.parquet.enable_row_group_prefetch = settings[Setting::input_format_parquet_enable_row_group_prefetch];
+    format_settings.parquet.allow_geoparquet_parser = settings[Setting::input_format_parquet_allow_geoparquet_parser];
     format_settings.pretty.charset = settings[Setting::output_format_pretty_grid_charset].toString() == "ASCII" ? FormatSettings::Pretty::Charset::ASCII : FormatSettings::Pretty::Charset::UTF8;
     format_settings.pretty.color = settings[Setting::output_format_pretty_color].valueOr(2);
     format_settings.pretty.glue_chunks = settings[Setting::output_format_pretty_glue_chunks].valueOr(2);
diff --git a/src/Formats/FormatSettings.h b/src/Formats/FormatSettings.h
@@ -304,6 +304,7 @@ struct FormatSettings
         size_t local_read_min_bytes_for_seek = 8192;
         double bloom_filter_bits_per_value = 10.5;
         size_t bloom_filter_flush_threshold_bytes = 1024 * 1024 * 128;
+        bool allow_geoparquet_parser = true;
     } parquet{};
 
     struct Pretty
diff --git a/src/Processors/Formats/Impl/ArrowBlockInputFormat.cpp b/src/Processors/Formats/Impl/ArrowBlockInputFormat.cpp
@@ -166,6 +166,7 @@ void ArrowBlockInputFormat::prepareReader()
         format_settings.arrow.allow_missing_columns,
         format_settings.null_as_default,
         format_settings.date_time_overflow_behavior,
+        format_settings.parquet.allow_geoparquet_parser,
         format_settings.arrow.case_insensitive_column_matching,
         stream);
 
@@ -212,7 +213,9 @@ NamesAndTypesList ArrowSchemaReader::readSchema()
         file_reader ? file_reader->metadata() : nullptr,
         stream ? "ArrowStream" : "Arrow",
         format_settings.arrow.skip_columns_with_unsupported_types_in_schema_inference,
-        format_settings.schema_inference_make_columns_nullable != 0);
+        format_settings.schema_inference_make_columns_nullable != 0,
+        false,
+        format_settings.parquet.allow_geoparquet_parser);
     if (format_settings.schema_inference_make_columns_nullable == 1)
         return getNamesAndRecursivelyNullableTypes(header, format_settings);
     return header.getNamesAndTypesList();
diff --git a/src/Processors/Formats/Impl/ArrowColumnToCHColumn.cpp b/src/Processors/Formats/Impl/ArrowColumnToCHColumn.cpp
@@ -482,8 +482,10 @@ static ColumnWithTypeAndName readColumnWithGeoData(const std::shared_ptr<arrow::
         {
             auto * raw_data = buffer->mutable_data() + chunk.value_offset(offset_i);
             if (chunk.IsNull(offset_i))
-                throw Exception(ErrorCodes::BAD_ARGUMENTS, "Geometry nullable columns are not supported");
-
+            {
+                column_builder.appendDefault();
+                continue;
+            }
             ReadBuffer in_buffer(reinterpret_cast<char*>(raw_data), chunk.value_length(offset_i), 0);
             ArrowGeometricObject result_object;
             switch (geo_metadata.encoding)
@@ -789,6 +791,7 @@ struct ReadColumnFromArrowColumnSettings
     bool skip_columns_with_unsupported_types;
     bool allow_inferring_nullable_columns;
     bool case_insensitive_matching;
+    bool allow_geoparquet_parser;
 };
 
 static ColumnWithTypeAndName readColumnFromArrowColumn(
@@ -846,7 +849,7 @@ static ColumnWithTypeAndName readNonNullableColumnFromArrowColumn(
                         break;
                 }
             }
-            if (geo_metadata)
+            if (geo_metadata && settings.allow_geoparquet_parser)
             {
                 return readColumnWithGeoData(arrow_column, column_name, *geo_metadata);
             }
@@ -1324,7 +1327,8 @@ Block ArrowColumnToCHColumn::arrowSchemaToCHHeader(
     const std::string & format_name,
     bool skip_columns_with_unsupported_types,
     bool allow_inferring_nullable_columns,
-    bool case_insensitive_matching)
+    bool case_insensitive_matching,
+    bool allow_geoparquet_parser)
 {
     ReadColumnFromArrowColumnSettings settings
     {
@@ -1333,7 +1337,8 @@ Block ArrowColumnToCHColumn::arrowSchemaToCHHeader(
         .allow_arrow_null_type = false,
         .skip_columns_with_unsupported_types = skip_columns_with_unsupported_types,
         .allow_inferring_nullable_columns = allow_inferring_nullable_columns,
-        .case_insensitive_matching = case_insensitive_matching
+        .case_insensitive_matching = case_insensitive_matching,
+        .allow_geoparquet_parser = allow_geoparquet_parser
     };
 
     ColumnsWithTypeAndName sample_columns;
@@ -1371,13 +1376,15 @@ ArrowColumnToCHColumn::ArrowColumnToCHColumn(
     bool allow_missing_columns_,
     bool null_as_default_,
     FormatSettings::DateTimeOverflowBehavior date_time_overflow_behavior_,
+    bool allow_geoparquet_parser_,
     bool case_insensitive_matching_,
     bool is_stream_)
     : header(header_)
     , format_name(format_name_)
     , allow_missing_columns(allow_missing_columns_)
     , null_as_default(null_as_default_)
     , date_time_overflow_behavior(date_time_overflow_behavior_)
+    , allow_geoparquet_parser(allow_geoparquet_parser_)
     , case_insensitive_matching(case_insensitive_matching_)
     , is_stream(is_stream_)
 {
@@ -1421,7 +1428,8 @@ Chunk ArrowColumnToCHColumn::arrowColumnsToCHChunk(
         .allow_arrow_null_type = true,
         .skip_columns_with_unsupported_types = false,
         .allow_inferring_nullable_columns = true,
-        .case_insensitive_matching = case_insensitive_matching
+        .case_insensitive_matching = case_insensitive_matching,
+        .allow_geoparquet_parser = allow_geoparquet_parser
     };
 
     Columns columns;
diff --git a/src/Processors/Formats/Impl/ArrowColumnToCHColumn.h b/src/Processors/Formats/Impl/ArrowColumnToCHColumn.h
@@ -27,6 +27,7 @@ class ArrowColumnToCHColumn
         bool allow_missing_columns_,
         bool null_as_default_,
         FormatSettings::DateTimeOverflowBehavior date_time_overflow_behavior_,
+        bool allow_geoparquet_parser_,
         bool case_insensitive_matching_ = false,
         bool is_stream_ = false);
 
@@ -43,7 +44,8 @@ class ArrowColumnToCHColumn
         const std::string & format_name,
         bool skip_columns_with_unsupported_types = false,
         bool allow_inferring_nullable_columns = true,
-        bool case_insensitive_matching = false);
+        bool case_insensitive_matching = false,
+        bool allow_geoparquet_parser = true);
 
     struct DictionaryInfo
     {
@@ -73,6 +75,7 @@ class ArrowColumnToCHColumn
     bool allow_missing_columns;
     bool null_as_default;
     FormatSettings::DateTimeOverflowBehavior date_time_overflow_behavior;
+    bool allow_geoparquet_parser;
     bool case_insensitive_matching;
     bool is_stream;
 
diff --git a/src/Processors/Formats/Impl/ArrowGeoTypes.cpp b/src/Processors/Formats/Impl/ArrowGeoTypes.cpp
@@ -321,6 +321,12 @@ void PointColumnBuilder::appendObject(const ArrowGeometricObject & object)
     point_column_data_y.push_back(point.y);
 }
 
+void PointColumnBuilder::appendDefault()
+{
+    point_column_data_x.push_back(0);
+    point_column_data_y.push_back(0);
+}
+
 ColumnWithTypeAndName PointColumnBuilder::getResultColumn()
 {
     ColumnPtr result_x = point_column_x->getPtr();
@@ -356,6 +362,11 @@ void LineColumnBuilder::appendObject(const ArrowGeometricObject & object)
     offsets.push_back(offset);
 }
 
+void LineColumnBuilder::appendDefault()
+{
+    offsets.push_back(offset);
+}
+
 ColumnWithTypeAndName LineColumnBuilder::getResultColumn()
 {
     auto all_points_column = point_column_builder.getResultColumn();
@@ -385,6 +396,11 @@ void PolygonColumnBuilder::appendObject(const ArrowGeometricObject & object)
     offsets.push_back(offset);
 }
 
+void PolygonColumnBuilder::appendDefault()
+{
+    offsets.push_back(offset);
+}
+
 ColumnWithTypeAndName PolygonColumnBuilder::getResultColumn()
 {
     auto all_points_column = line_column_builder.getResultColumn();
@@ -415,6 +431,11 @@ void MultiLineStringColumnBuilder::appendObject(const ArrowGeometricObject & obj
     offsets.push_back(offset);
 }
 
+void MultiLineStringColumnBuilder::appendDefault()
+{
+    offsets.push_back(offset);
+}
+
 ColumnWithTypeAndName MultiLineStringColumnBuilder::getResultColumn()
 {
     auto all_points_column = line_column_builder.getResultColumn();
@@ -445,6 +466,11 @@ void MultiPolygonColumnBuilder::appendObject(const ArrowGeometricObject & object
     offsets.push_back(offset);
 }
 
+void MultiPolygonColumnBuilder::appendDefault()
+{
+    offsets.push_back(offset);
+}
+
 ColumnWithTypeAndName MultiPolygonColumnBuilder::getResultColumn()
 {
     auto all_points_column = polygon_column_builder.getResultColumn();
@@ -482,6 +508,12 @@ void GeoColumnBuilder::appendObject(const ArrowGeometricObject & object)
     geomery_column_builder->appendObject(object);
 }
 
+void GeoColumnBuilder::appendDefault()
+{
+    geomery_column_builder->appendDefault();
+}
+
+
 ColumnWithTypeAndName GeoColumnBuilder::getResultColumn()
 {
     return geomery_column_builder->getResultColumn();
diff --git a/src/Processors/Formats/Impl/ArrowGeoTypes.h b/src/Processors/Formats/Impl/ArrowGeoTypes.h
@@ -62,6 +62,7 @@ using ArrowGeometricObject = std::variant<ArrowPoint, ArrowLineString, ArrowPoly
 struct IGeometryColumnBuilder
 {
     virtual void appendObject(const ArrowGeometricObject & object) = 0;
+    virtual void appendDefault() = 0;
     virtual ColumnWithTypeAndName getResultColumn() = 0;
 
     virtual ~IGeometryColumnBuilder() = default;
@@ -73,6 +74,7 @@ class PointColumnBuilder : public IGeometryColumnBuilder
     explicit PointColumnBuilder(const String & name_);
 
     void appendObject(const ArrowGeometricObject & object) override;
+    void appendDefault() override;
 
     ColumnWithTypeAndName getResultColumn() override;
 
@@ -93,6 +95,7 @@ class LineColumnBuilder : public IGeometryColumnBuilder
     explicit LineColumnBuilder(const String & name_);
 
     void appendObject(const ArrowGeometricObject & object) override;
+    void appendDefault() override;
 
     ColumnWithTypeAndName getResultColumn() override;
 
@@ -114,6 +117,7 @@ class PolygonColumnBuilder : public IGeometryColumnBuilder
     explicit PolygonColumnBuilder(const String & name_);
 
     void appendObject(const ArrowGeometricObject & object) override;
+    void appendDefault() override;
 
     ColumnWithTypeAndName getResultColumn() override;
 
@@ -135,6 +139,7 @@ class MultiLineStringColumnBuilder : public IGeometryColumnBuilder
     explicit MultiLineStringColumnBuilder(const String & name_);
 
     void appendObject(const ArrowGeometricObject & object) override;
+    void appendDefault() override;
 
     ColumnWithTypeAndName getResultColumn() override;
 
@@ -156,6 +161,7 @@ class MultiPolygonColumnBuilder : public IGeometryColumnBuilder
     explicit MultiPolygonColumnBuilder(const String & name_);
 
     void appendObject(const ArrowGeometricObject & object) override;
+    void appendDefault() override;
 
     ColumnWithTypeAndName getResultColumn() override;
 
@@ -178,6 +184,7 @@ class GeoColumnBuilder : public IGeometryColumnBuilder
     explicit GeoColumnBuilder(const String & name_, GeoType type_);
 
     void appendObject(const ArrowGeometricObject & object) override;
+    void appendDefault() override;
 
     ColumnWithTypeAndName getResultColumn() override;
 
diff --git a/src/Processors/Formats/Impl/ORCBlockInputFormat.cpp b/src/Processors/Formats/Impl/ORCBlockInputFormat.cpp
@@ -140,6 +140,7 @@ void ORCBlockInputFormat::prepareReader()
         format_settings.orc.allow_missing_columns,
         format_settings.null_as_default,
         format_settings.date_time_overflow_behavior,
+        format_settings.parquet.allow_geoparquet_parser,
         format_settings.orc.case_insensitive_column_matching);
 
     const bool ignore_case = format_settings.orc.case_insensitive_column_matching;
@@ -174,12 +175,15 @@ void ORCSchemaReader::initializeIfNeeded()
 NamesAndTypesList ORCSchemaReader::readSchema()
 {
     initializeIfNeeded();
+
     auto header = ArrowColumnToCHColumn::arrowSchemaToCHHeader(
         *schema,
         metadata,
         "ORC",
         format_settings.orc.skip_columns_with_unsupported_types_in_schema_inference,
-        format_settings.schema_inference_make_columns_nullable != 0);
+        format_settings.schema_inference_make_columns_nullable != 0,
+        false,
+        format_settings.parquet.allow_geoparquet_parser);
     if (format_settings.schema_inference_make_columns_nullable == 1)
         return getNamesAndRecursivelyNullableTypes(header, format_settings);
     return header.getNamesAndTypesList();
diff --git a/src/Processors/Formats/Impl/ParquetBlockInputFormat.cpp b/src/Processors/Formats/Impl/ParquetBlockInputFormat.cpp
@@ -866,6 +866,7 @@ void ParquetBlockInputFormat::initializeRowGroupBatchReader(size_t row_group_bat
             format_settings.parquet.allow_missing_columns,
             format_settings.null_as_default,
             format_settings.date_time_overflow_behavior,
+            format_settings.parquet.allow_geoparquet_parser,
             format_settings.parquet.case_insensitive_column_matching);
     }
 }
@@ -1184,7 +1185,8 @@ NamesAndTypesList ParquetSchemaReader::readSchema()
         "Parquet",
         format_settings.parquet.skip_columns_with_unsupported_types_in_schema_inference,
         format_settings.schema_inference_make_columns_nullable != 0,
-        format_settings.parquet.case_insensitive_column_matching);
+        format_settings.parquet.case_insensitive_column_matching,
+        format_settings.parquet.allow_geoparquet_parser);
     if (format_settings.schema_inference_make_columns_nullable == 1)
         return getNamesAndRecursivelyNullableTypes(header, format_settings);
     return header.getNamesAndTypesList();
diff --git a/src/Storages/ObjectStorage/DataLakes/DeltaLakeMetadata.cpp b/src/Storages/ObjectStorage/DataLakes/DeltaLakeMetadata.cpp
@@ -500,6 +500,7 @@ struct DeltaLakeMetadataImpl
             format_settings.parquet.allow_missing_columns,
             /* null_as_default */true,
             format_settings.date_time_overflow_behavior,
+            format_settings.parquet.allow_geoparquet_parser,
             /* case_insensitive_column_matching */false);
 
         std::shared_ptr<arrow::Table> table;
diff --git a/tests/queries/0_stateless/03445_geoparquet.reference b/tests/queries/0_stateless/03445_geoparquet.reference
@@ -2,3 +2,11 @@
 (1,1)	[(1,1),(2,4),(5,5)]	[[(3,3),(4,3),(4,4),(3,4),(3,3)]]	[[(0,0),(5,5)],[(1,1),(2,4),(5,5)]]	[[[(1,1),(2,1),(2,2),(1,2),(1,1)]],[[(3,3),(4,3),(4,4),(3,4),(3,3)]]]
 1	(30,10)	[(30,10),(10,30),(40,40)]	[[(35,10),(45,45),(15,40),(10,20),(35,10)],[(20,30),(35,35),(30,20),(20,30)]]
 2	(40,20)	[(40,20),(20,40),(50,50)]	[[(35,10),(45,45),(15,40),(10,20),(35,10)]]
+(1,1)	Point1
+(0,0)	Point2
+[(0,0),(1,1)]	linestring1
+[]	linestring2
+[[(0,0),(2,0),(2,2),(0,2),(0,0)]]	Polygon1
+[]	Polygon2
+\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0	\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0@\0\0\0\0\0\0@	\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0�?\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0\0@\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0�?\0\0\0\0\0\0�?	\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0@\0\0\0\0\0\0@\0\0\0\0\0\0\0\0\0\0\0\0�?\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0@\0\0\0\0\0\0@\0\0\0\0\0\0@	\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0�?\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0\0@\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0�?\0\0\0\0\0\0�?\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\b@\0\0\0\0\0\0\b@\0\0\0\0\0\0@\0\0\0\0\0\0\b@\0\0\0\0\0\0@\0\0\0\0\0\0@\0\0\0\0\0\0\b@\0\0\0\0\0\0@\0\0\0\0\0\0\b@\0\0\0\0\0\0\b@
+\0\0\0\0\0\0\0\0\0�?\0\0\0\0\0\0�?	\0\0\0\0\0\0\0\0\0\0\0\0�?\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0@\0\0\0\0\0\0@\0\0\0\0\0\0@	\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\b@\0\0\0\0\0\0\b@\0\0\0\0\0\0@\0\0\0\0\0\0\b@\0\0\0\0\0\0@\0\0\0\0\0\0@\0\0\0\0\0\0\b@\0\0\0\0\0\0@\0\0\0\0\0\0\b@\0\0\0\0\0\0\b@	\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0@\0\0\0\0\0\0@\0\0\0\0\0\0\0\0\0\0\0\0�?\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0@\0\0\0\0\0\0@\0\0\0\0\0\0@	\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0�?\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0\0@\0\0\0\0\0\0�?\0\0\0\0\0\0\0@\0\0\0\0\0\0�?\0\0\0\0\0\0�?\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\b@\0\0\0\0\0\0\b@\0\0\0\0\0\0@\0\0\0\0\0\0\b@\0\0\0\0\0\0@\0\0\0\0\0\0@\0\0\0\0\0\0\b@\0\0\0\0\0\0@\0\0\0\0\0\0\b@\0\0\0\0\0\0\b@
diff --git a/tests/queries/0_stateless/03445_geoparquet.sh b/tests/queries/0_stateless/03445_geoparquet.sh
@@ -7,3 +7,7 @@ CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
 
 $CLICKHOUSE_LOCAL -q "select * from file('$CURDIR/data_parquet/03445_geoparquet_wkb.parquet', Parquet)"
 $CLICKHOUSE_LOCAL -q "select * from file('$CURDIR/data_parquet/03445_geoparquet_wkt.parquet', Parquet)"
+$CLICKHOUSE_LOCAL -q "select * from file('$CURDIR/data_parquet/03445_geoparquet_null_point.parquet', Parquet)"
+$CLICKHOUSE_LOCAL -q "select * from file('$CURDIR/data_parquet/03445_geoparquet_null_linestring.parquet', Parquet)"
+$CLICKHOUSE_LOCAL -q "select * from file('$CURDIR/data_parquet/03445_geoparquet_null_polygon.parquet', Parquet)"
+$CLICKHOUSE_LOCAL -q "select * from file('$CURDIR/data_parquet/03445_geoparquet_wkb.parquet', Parquet) SETTINGS input_format_parquet_allow_geoparquet_parser=false;"
diff --git a/tests/queries/0_stateless/data_parquet/03445_geoparquet_null_linestring.parquet b/tests/queries/0_stateless/data_parquet/03445_geoparquet_null_linestring.parquet
diff --git a/tests/queries/0_stateless/data_parquet/03445_geoparquet_null_point.parquet b/tests/queries/0_stateless/data_parquet/03445_geoparquet_null_point.parquet
diff --git a/tests/queries/0_stateless/data_parquet/03445_geoparquet_null_polygon.parquet b/tests/queries/0_stateless/data_parquet/03445_geoparquet_null_polygon.parquet

Original file line number	Diff line number	Diff line change
`@@ -100,6 +100,7 @@ const VersionToSettingsChangesMap & getSettingsChangesHistory()`
`100`	`100`	`{"allow_experimental_database_hms_catalog", false, false, "Allow experimental database engine DataLakeCatalog with catalog_type = 'hive'"},`
`101`	`101`	`{"compile_expressions", false, true, "We believe that the LLVM infrastructure behind the JIT compiler is stable enough to enable this setting by default."},`
`102`	`102`	`{"use_legacy_to_time", false, false, "New setting. Allows for user to use the old function logic for toTime, which works as toTimeWithFixedDate."},`
	`103`	`+ {"input_format_parquet_allow_geoparquet_parser", false, true, "A new setting to use geo columns in parquet file"},`
`103`	`104`	`});`
`104`	`105`	`addSettingsChanges(settings_changes_history, "25.4",`
`105`	`106`	`{`
Original file line number	Diff line number	Diff line change
`@@ -321,6 +321,12 @@ void PointColumnBuilder::appendObject(const ArrowGeometricObject & object)`
`321`	`321`	`point_column_data_y.push_back(point.y);`
`322`	`322`	`}`
`323`	`323`
	`324`	`+void PointColumnBuilder::appendDefault()`
	`325`	`+{`
	`326`	`+ point_column_data_x.push_back(0);`
	`327`	`+ point_column_data_y.push_back(0);`
	`328`	`+}`
	`329`	`+`
`324`	`330`	`ColumnWithTypeAndName PointColumnBuilder::getResultColumn()`
`325`	`331`	`{`
`326`	`332`	`ColumnPtr result_x = point_column_x->getPtr();`
`@@ -356,6 +362,11 @@ void LineColumnBuilder::appendObject(const ArrowGeometricObject & object)`
`356`	`362`	`offsets.push_back(offset);`
`357`	`363`	`}`
`358`	`364`
	`365`	`+void LineColumnBuilder::appendDefault()`
	`366`	`+{`
	`367`	`+ offsets.push_back(offset);`
	`368`	`+}`
	`369`	`+`
`359`	`370`	`ColumnWithTypeAndName LineColumnBuilder::getResultColumn()`
`360`	`371`	`{`
`361`	`372`	`auto all_points_column = point_column_builder.getResultColumn();`
`@@ -385,6 +396,11 @@ void PolygonColumnBuilder::appendObject(const ArrowGeometricObject & object)`
`385`	`396`	`offsets.push_back(offset);`
`386`	`397`	`}`
`387`	`398`
	`399`	`+void PolygonColumnBuilder::appendDefault()`
	`400`	`+{`
	`401`	`+ offsets.push_back(offset);`
	`402`	`+}`
	`403`	`+`
`388`	`404`	`ColumnWithTypeAndName PolygonColumnBuilder::getResultColumn()`
`389`	`405`	`{`
`390`	`406`	`auto all_points_column = line_column_builder.getResultColumn();`
`@@ -415,6 +431,11 @@ void MultiLineStringColumnBuilder::appendObject(const ArrowGeometricObject & obj`
`415`	`431`	`offsets.push_back(offset);`
`416`	`432`	`}`
`417`	`433`
	`434`	`+void MultiLineStringColumnBuilder::appendDefault()`
	`435`	`+{`
	`436`	`+ offsets.push_back(offset);`
	`437`	`+}`
	`438`	`+`
`418`	`439`	`ColumnWithTypeAndName MultiLineStringColumnBuilder::getResultColumn()`
`419`	`440`	`{`
`420`	`441`	`auto all_points_column = line_column_builder.getResultColumn();`
`@@ -445,6 +466,11 @@ void MultiPolygonColumnBuilder::appendObject(const ArrowGeometricObject & object`
`445`	`466`	`offsets.push_back(offset);`
`446`	`467`	`}`
`447`	`468`
	`469`	`+void MultiPolygonColumnBuilder::appendDefault()`
	`470`	`+{`
	`471`	`+ offsets.push_back(offset);`
	`472`	`+}`
	`473`	`+`
`448`	`474`	`ColumnWithTypeAndName MultiPolygonColumnBuilder::getResultColumn()`
`449`	`475`	`{`
`450`	`476`	`auto all_points_column = polygon_column_builder.getResultColumn();`
`@@ -482,6 +508,12 @@ void GeoColumnBuilder::appendObject(const ArrowGeometricObject & object)`
`482`	`508`	`geomery_column_builder->appendObject(object);`
`483`	`509`	`}`
`484`	`510`
	`511`	`+void GeoColumnBuilder::appendDefault()`
	`512`	`+{`
	`513`	`+ geomery_column_builder->appendDefault();`
	`514`	`+}`
	`515`	`+`
	`516`	`+`
`485`	`517`	`ColumnWithTypeAndName GeoColumnBuilder::getResultColumn()`
`486`	`518`	`{`
`487`	`519`	`return geomery_column_builder->getResultColumn();`