Update Integer Delta Append (rtdip#510)

Signed-off-by: GBBBAS <[email protected]>
GBBBAS · Sep 26, 2023 · 3d3a1a0 · 3d3a1a0
1 parent 82f4c35
commit 3d3a1a0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/sdk/python/rtdip_sdk/pipelines/destinations/spark/pcdm_to_delta.py b/src/sdk/python/rtdip_sdk/pipelines/destinations/spark/pcdm_to_delta.py
@@ -330,9 +330,9 @@ def write_stream(self):
 
                 if self.destination_integer != None:
                     delta_integer = SparkDeltaDestination(
-                        data=self.data.select(
-                            "TagName", "EventTime", "Status", "Value"
-                        ).filter(ValueTypeConstants.INTEGER_VALUE),
+                        data=self.data.select("TagName", "EventTime", "Status", "Value")
+                        .filter(ValueTypeConstants.INTEGER_VALUE)
+                        .withColumn("Value", col("Value").cast("integer")),
                         destination=self.destination_integer,
                         options=self.options,
                         mode=self.mode,