diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SessionEvent.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SessionEvent.scala index 610b1645c2f..5f04945ef8c 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SessionEvent.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SessionEvent.scala @@ -36,6 +36,10 @@ import org.apache.kyuubi.events.KyuubiEvent * @param ip Client IP address * @param serverIp Kyuubi Server IP address * @param totalOperations how many queries and meta calls + * @param sessionRunTime total time of running the session (including fetching shuffle data) + * in milliseconds + * @param sessionCpuTime total CPU time of running the session (including fetching shuffle data) + * in nanoseconds */ case class SessionEvent( @KVIndexParam sessionId: String, diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SparkOperationEvent.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SparkOperationEvent.scala index 4b529cdafb9..143ba61f843 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SparkOperationEvent.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SparkOperationEvent.scala @@ -46,6 +46,10 @@ import org.apache.kyuubi.events.KyuubiEvent * @param sessionId the identifier of the parent session * @param sessionUser the authenticated client user * @param executionId the query execution id of this operation + * @param operationRunTime total time of running the operation (including fetching shuffle data) + * in milliseconds + * @param operationCpuTime total CPU time of running the operation (including fetching shuffle data) + * in nanoseconds */ case class SparkOperationEvent( @KVIndexParam statementId: String,