This is an automated email from the ASF dual-hosted git repository.
dongjoon pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/spark-connect-swift.git
The following commit(s) were added to refs/heads/main by this push:
new 10f2854 [SPARK-52070] Fix `Swift 6.0` compilation error
10f2854 is described below
commit 10f2854965bf3a47ec886d4931a4cc6703bd535e
Author: William Hyun <[email protected]>
AuthorDate: Sun May 11 11:27:58 2025 -0700
[SPARK-52070] Fix `Swift 6.0` compilation error
### What changes were proposed in this pull request?
This PR aims to fix the build for Swift 6.0.
### Why are the changes needed?
Currently, the build on Swift 6.0 is broken due to a syntax error.
- https://swiftpackageindex.com/apache/spark-connect-swift/builds
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
Pass the CIs.
### Was this patch authored or co-authored using generative AI tooling?
No.
Closes #127 from williamhyun/switft6.
Authored-by: William Hyun <[email protected]>
Signed-off-by: Dongjoon Hyun <[email protected]>
---
Sources/SparkConnect/DataFrame.swift | 2 +-
Sources/SparkConnect/SparkConnectClient.swift | 4 ++--
Sources/SparkConnect/StreamingQuery.swift | 4 ++--
3 files changed, 5 insertions(+), 5 deletions(-)
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)
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
)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
