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 ) }