File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff 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
Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments