Small iceberg read optimization optimization

ianton-ru · ianton-ru · commit ff7562b89f52 · 2025-10-28T15:16:23.000+01:00
diff --git a/src/Interpreters/ClusterFunctionReadTask.cpp b/src/Interpreters/ClusterFunctionReadTask.cpp
@@ -19,6 +19,7 @@ namespace ErrorCodes
 namespace Setting
 {
     extern const SettingsBool cluster_function_process_archive_on_multiple_nodes;
+    extern const SettingsBool allow_experimental_iceberg_read_optimization;
 }
 
 ClusterFunctionReadTaskResponse::ClusterFunctionReadTaskResponse(ObjectInfoPtr object, const ContextPtr & context)
@@ -29,7 +30,8 @@ ClusterFunctionReadTaskResponse::ClusterFunctionReadTaskResponse(ObjectInfoPtr o
     if (object->data_lake_metadata.has_value())
         data_lake_metadata = object->data_lake_metadata.value();
 
-    file_meta_info = object->file_meta_info;
+    if (context->getSettingsRef()[Setting::allow_experimental_iceberg_read_optimization])
+        file_meta_info = object->file_meta_info;
 
     const bool send_over_whole_archive = !context->getSettingsRef()[Setting::cluster_function_process_archive_on_multiple_nodes];
     path = send_over_whole_archive ? object->getPathOrPathToArchiveIfArchive() : object->getPath();

Original file line number	Diff line number	Diff line change
`@@ -19,6 +19,7 @@ namespace ErrorCodes`
`19`	`19`	`namespace Setting`
`20`	`20`	`{`
`21`	`21`	`extern const SettingsBool cluster_function_process_archive_on_multiple_nodes;`
	`22`	`+ extern const SettingsBool allow_experimental_iceberg_read_optimization;`
`22`	`23`	`}`
`23`	`24`
`24`	`25`	`ClusterFunctionReadTaskResponse::ClusterFunctionReadTaskResponse(ObjectInfoPtr object, const ContextPtr & context)`
`@@ -29,7 +30,8 @@ ClusterFunctionReadTaskResponse::ClusterFunctionReadTaskResponse(ObjectInfoPtr o`
`29`	`30`	`if (object->data_lake_metadata.has_value())`
`30`	`31`	`data_lake_metadata = object->data_lake_metadata.value();`
`31`	`32`
`32`		`- file_meta_info = object->file_meta_info;`
	`33`	`+ if (context->getSettingsRef()[Setting::allow_experimental_iceberg_read_optimization])`
	`34`	`+ file_meta_info = object->file_meta_info;`
`33`	`35`
`34`	`36`	`const bool send_over_whole_archive = !context->getSettingsRef()[Setting::cluster_function_process_archive_on_multiple_nodes];`
`35`	`37`	`path = send_over_whole_archive ? object->getPathOrPathToArchiveIfArchive() : object->getPath();`