[native] Pass serde parameters down to insert table handle

prestodb · Oct 29, 2023 · 061c340 · 061c340
1 parent 83b20c0
commit 061c340
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/presto-native-execution/presto_cpp/main/types/PrestoToVeloxQueryPlan.cpp b/presto-native-execution/presto_cpp/main/types/PrestoToVeloxQueryPlan.cpp
@@ -2253,14 +2253,19 @@ VeloxQueryPlanConverterBase::toVeloxQueryPlan(
         "Bucketed table must be partitioned: {}",
         toJsonString(*hiveInsertTableHandle));
 
+    const auto table = hiveInsertTableHandle->pageSinkMetadata.table;
+    VELOX_USER_CHECK_NOT_NULL(table, "Table must not be null for insert query");
     hiveTableHandle = std::make_shared<connector::hive::HiveInsertTableHandle>(
         inputColumns,
         toLocationHandle(hiveInsertTableHandle->locationHandle),
         toFileFormat(hiveInsertTableHandle->tableStorageFormat, "TableWrite"),
         toHiveBucketProperty(
             inputColumns, hiveInsertTableHandle->bucketProperty),
         std::optional(
-            toFileCompressionKind(hiveInsertTableHandle->compressionCodec)));
+            toFileCompressionKind(hiveInsertTableHandle->compressionCodec)),
+        std::unordered_map<std::string, std::string>(
+            table->storage.serdeParameters.begin(),
+            table->storage.serdeParameters.end()));
   } else {
     VELOX_UNSUPPORTED(
         "Unsupported table writer handle: {}",