From 6b102874e40aa68e6634f1306dbd1e6a10ce387a Mon Sep 17 00:00:00 2001 From: William Hyun Date: Sun, 11 May 2025 11:06:32 -0700 Subject: [PATCH 1/2] Fix Switft 6 Build --- Sources/SparkConnect/SparkConnectClient.swift | 4 ++-- Sources/SparkConnect/StreamingQuery.swift | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/Sources/SparkConnect/SparkConnectClient.swift b/Sources/SparkConnect/SparkConnectClient.swift index de019b8..943131d 100644 --- a/Sources/SparkConnect/SparkConnectClient.swift +++ b/Sources/SparkConnect/SparkConnectClient.swift @@ -925,7 +925,7 @@ public actor SparkConnectClient { _ ids: [String], _ values: [String]?, _ variableColumnName: String, - _ valueColumnName: String, + _ valueColumnName: String ) -> Plan { var unpivot = Spark_Connect_Unpivot() unpivot.input = child @@ -984,7 +984,7 @@ public actor SparkConnectClient { func executeStreamingQueryCommand( _ id: String, _ runID: String, - _ command: StreamingQueryCommand.OneOf_Command, + _ command: StreamingQueryCommand.OneOf_Command ) async throws -> [ExecutePlanResponse] { var queryID = Spark_Connect_StreamingQueryInstanceId() queryID.id = id diff --git a/Sources/SparkConnect/StreamingQuery.swift b/Sources/SparkConnect/StreamingQuery.swift index 6d62f2e..2758a5e 100644 --- a/Sources/SparkConnect/StreamingQuery.swift +++ b/Sources/SparkConnect/StreamingQuery.swift @@ -86,7 +86,7 @@ public actor StreamingQuery: Sendable { return StreamingQueryException( exceptionMessage: result.exceptionMessage, errorClass: result.errorClass, - stackTrace: result.stackTrace, + stackTrace: result.stackTrace ) } @@ -99,7 +99,7 @@ public actor StreamingQuery: Sendable { statusMessage: result.statusMessage, isDataAvailable: result.isDataAvailable, isTriggerActive: result.isTriggerActive, - isActive: result.isActive, + isActive: result.isActive ) } From a0c142930879c6ce682c2b11f58a1af71be3d1ff Mon Sep 17 00:00:00 2001 From: William Hyun Date: Sun, 11 May 2025 11:19:39 -0700 Subject: [PATCH 2/2] Missed File --- Sources/SparkConnect/DataFrame.swift | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Sources/SparkConnect/DataFrame.swift b/Sources/SparkConnect/DataFrame.swift index ff30f25..f984017 100644 --- a/Sources/SparkConnect/DataFrame.swift +++ b/Sources/SparkConnect/DataFrame.swift @@ -1285,7 +1285,7 @@ public actor DataFrame: Sendable { _ ids: [String], _ values: [String]?, _ variableColumnName: String, - _ valueColumnName: String, + _ valueColumnName: String ) -> DataFrame { let plan = SparkConnectClient.getUnpivot(self.plan.root, ids, values, variableColumnName, valueColumnName) return DataFrame(spark: self.spark, plan: plan)