Add additional properties when doing conversion for hudi

Author: rahil-c

xtable-service/src/main/java/org/apache/xtable/service/ConversionService.java

@@ -19,6 +19,7 @@
 package org.apache.xtable.service;
 
 import static org.apache.xtable.conversion.ConversionUtils.convertToSourceTable;
+import static org.apache.xtable.hudi.HudiSourceConfig.PARTITION_FIELD_SPEC_CONFIG;
 import static org.apache.xtable.model.storage.TableFormat.DELTA;
 import static org.apache.xtable.model.storage.TableFormat.HUDI;
 import static org.apache.xtable.model.storage.TableFormat.ICEBERG;
@@ -27,6 +28,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Properties;
 
 import lombok.extern.log4j.Log4j2;
 
@@ -186,11 +188,19 @@ public ConversionService(
    * @return a ConvertTableResponse containing details of the converted target tables
    */
   public ConvertTableResponse convertTable(ConvertTableRequest convertTableRequest) {
+
+    Properties sourceProperties = new Properties();
+    String partitionSpec = convertTableRequest.getConfigurations().getOrDefault("partition-spec", null);
+    if (partitionSpec != null) {
+      sourceProperties.put(PARTITION_FIELD_SPEC_CONFIG, partitionSpec);
+    }
+
     SourceTable sourceTable =
         SourceTable.builder()
             .name(convertTableRequest.getSourceTableName())
             .basePath(convertTableRequest.getSourceTablePath())
             .formatName(convertTableRequest.getSourceFormat())
+            .additionalProperties(sourceProperties)
             .build();
 
     List<TargetTable> targetTables = new ArrayList<>();
@@ -200,6 +210,7 @@ public ConvertTableResponse convertTable(ConvertTableRequest convertTableRequest
               .name(convertTableRequest.getSourceTableName())
               .basePath(convertTableRequest.getSourceTablePath())
               .formatName(targetFormat)
+              .additionalProperties(sourceProperties)
               .build();
       targetTables.add(targetTable);
     }