Update API CreateApsKafkaHudiJob: add request parameters DataFormatType.

Author: sdk-team

adb-20211201/ChangeLog.md

@@ -1,3 +1,7 @@
+2025-12-03 Version: 3.6.1
+- Update API CreateApsKafkaHudiJob: add request parameters DataFormatType.
+
+
 2025-12-02 Version: 3.6.0
 - Support API DeleteMaterializedViewRecommend.
 - Support API DescribeMVRecommendResults.

adb-20211201/alibabacloud_adb20211201/__init__.py

@@ -1 +1 @@
-__version__ = '3.6.0'
+__version__ = '3.6.1'

adb-20211201/alibabacloud_adb20211201/client.py

@@ -2061,6 +2061,8 @@ def create_aps_kafka_hudi_job_with_options(
             body['Columns'] = request.columns_shrink
         if not UtilClient.is_unset(request.dbcluster_id):
             body['DBClusterId'] = request.dbcluster_id
+        if not UtilClient.is_unset(request.data_format_type):
+            body['DataFormatType'] = request.data_format_type
         if not UtilClient.is_unset(request.data_output_format):
             body['DataOutputFormat'] = request.data_output_format
         if not UtilClient.is_unset(request.datasource_id):
@@ -2156,6 +2158,8 @@ async def create_aps_kafka_hudi_job_with_options_async(
             body['Columns'] = request.columns_shrink
         if not UtilClient.is_unset(request.dbcluster_id):
             body['DBClusterId'] = request.dbcluster_id
+        if not UtilClient.is_unset(request.data_format_type):
+            body['DataFormatType'] = request.data_format_type
         if not UtilClient.is_unset(request.data_output_format):
             body['DataOutputFormat'] = request.data_output_format
         if not UtilClient.is_unset(request.datasource_id):

adb-20211201/alibabacloud_adb20211201/models.py

@@ -6140,6 +6140,7 @@ def __init__(
         advanced_config: str = None,
         columns: List[CreateApsKafkaHudiJobRequestColumns] = None,
         dbcluster_id: str = None,
+        data_format_type: str = None,
         data_output_format: str = None,
         datasource_id: int = None,
         db_name: str = None,
@@ -6180,6 +6181,7 @@ def __init__(
         # 
         # This parameter is required.
         self.dbcluster_id = dbcluster_id
+        self.data_format_type = data_format_type
         # Enumeration value and description. Single: The source is a single-row JSON record. Multi: source is a JSON array. Output a single JSON record.
         self.data_output_format = data_output_format
         # The data source ID.
@@ -6265,6 +6267,8 @@ def to_map(self):
                 result['Columns'].append(k.to_map() if k else None)
         if self.dbcluster_id is not None:
             result['DBClusterId'] = self.dbcluster_id
+        if self.data_format_type is not None:
+            result['DataFormatType'] = self.data_format_type
         if self.data_output_format is not None:
             result['DataOutputFormat'] = self.data_output_format
         if self.datasource_id is not None:
@@ -6328,6 +6332,8 @@ def from_map(self, m: dict = None):
                 self.columns.append(temp_model.from_map(k))
         if m.get('DBClusterId') is not None:
             self.dbcluster_id = m.get('DBClusterId')
+        if m.get('DataFormatType') is not None:
+            self.data_format_type = m.get('DataFormatType')
         if m.get('DataOutputFormat') is not None:
             self.data_output_format = m.get('DataOutputFormat')
         if m.get('DatasourceId') is not None:
@@ -6385,6 +6391,7 @@ def __init__(
         advanced_config: str = None,
         columns_shrink: str = None,
         dbcluster_id: str = None,
+        data_format_type: str = None,
         data_output_format: str = None,
         datasource_id: int = None,
         db_name: str = None,
@@ -6425,6 +6432,7 @@ def __init__(
         # 
         # This parameter is required.
         self.dbcluster_id = dbcluster_id
+        self.data_format_type = data_format_type
         # Enumeration value and description. Single: The source is a single-row JSON record. Multi: source is a JSON array. Output a single JSON record.
         self.data_output_format = data_output_format
         # The data source ID.
@@ -6505,6 +6513,8 @@ def to_map(self):
             result['Columns'] = self.columns_shrink
         if self.dbcluster_id is not None:
             result['DBClusterId'] = self.dbcluster_id
+        if self.data_format_type is not None:
+            result['DataFormatType'] = self.data_format_type
         if self.data_output_format is not None:
             result['DataOutputFormat'] = self.data_output_format
         if self.datasource_id is not None:
@@ -6565,6 +6575,8 @@ def from_map(self, m: dict = None):
             self.columns_shrink = m.get('Columns')
         if m.get('DBClusterId') is not None:
             self.dbcluster_id = m.get('DBClusterId')
+        if m.get('DataFormatType') is not None:
+            self.data_format_type = m.get('DataFormatType')
         if m.get('DataOutputFormat') is not None:
             self.data_output_format = m.get('DataOutputFormat')
         if m.get('DatasourceId') is not None:

adb-20211201/setup.py

@@ -24,7 +24,7 @@
 """
 setup module for alibabacloud_adb20211201.
 
-Created on 02/12/2025
+Created on 03/12/2025
 
 @author: Alibaba Cloud SDK
 """