Skip to content

Commit 10f2854

Browse files
williamhyundongjoon-hyun
authored andcommitted
[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]>
1 parent 5c3c00f commit 10f2854

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

Sources/SparkConnect/DataFrame.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1285,7 +1285,7 @@ public actor DataFrame: Sendable {
12851285
_ ids: [String],
12861286
_ values: [String]?,
12871287
_ variableColumnName: String,
1288-
_ valueColumnName: String,
1288+
_ valueColumnName: String
12891289
) -> DataFrame {
12901290
let plan = SparkConnectClient.getUnpivot(self.plan.root, ids, values, variableColumnName, valueColumnName)
12911291
return DataFrame(spark: self.spark, plan: plan)

Sources/SparkConnect/SparkConnectClient.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -925,7 +925,7 @@ public actor SparkConnectClient {
925925
_ ids: [String],
926926
_ values: [String]?,
927927
_ variableColumnName: String,
928-
_ valueColumnName: String,
928+
_ valueColumnName: String
929929
) -> Plan {
930930
var unpivot = Spark_Connect_Unpivot()
931931
unpivot.input = child
@@ -984,7 +984,7 @@ public actor SparkConnectClient {
984984
func executeStreamingQueryCommand(
985985
_ id: String,
986986
_ runID: String,
987-
_ command: StreamingQueryCommand.OneOf_Command,
987+
_ command: StreamingQueryCommand.OneOf_Command
988988
) async throws -> [ExecutePlanResponse] {
989989
var queryID = Spark_Connect_StreamingQueryInstanceId()
990990
queryID.id = id

Sources/SparkConnect/StreamingQuery.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ public actor StreamingQuery: Sendable {
8686
return StreamingQueryException(
8787
exceptionMessage: result.exceptionMessage,
8888
errorClass: result.errorClass,
89-
stackTrace: result.stackTrace,
89+
stackTrace: result.stackTrace
9090
)
9191
}
9292

@@ -99,7 +99,7 @@ public actor StreamingQuery: Sendable {
9999
statusMessage: result.statusMessage,
100100
isDataAvailable: result.isDataAvailable,
101101
isTriggerActive: result.isTriggerActive,
102-
isActive: result.isActive,
102+
isActive: result.isActive
103103
)
104104
}
105105

0 commit comments

Comments
 (0)