diff --git a/kyuubi-rest-client/src/main/java/org/apache/kyuubi/client/api/v1/dto/SessionData.java b/kyuubi-rest-client/src/main/java/org/apache/kyuubi/client/api/v1/dto/SessionData.java index 233fee721..97da4d942 100644 --- a/kyuubi-rest-client/src/main/java/org/apache/kyuubi/client/api/v1/dto/SessionData.java +++ b/kyuubi-rest-client/src/main/java/org/apache/kyuubi/client/api/v1/dto/SessionData.java @@ -32,6 +32,7 @@ public class SessionData { private Long duration; private Long idleTime; private String exception; + private String sessionType; public SessionData() {} @@ -43,7 +44,8 @@ public class SessionData { Long createTime, Long duration, Long idleTime, - String exception) { + String exception, + String sessionType) { this.identifier = identifier; this.user = user; this.ipAddr = ipAddr; @@ -52,6 +54,7 @@ public class SessionData { this.duration = duration; this.idleTime = idleTime; this.exception = exception; + this.sessionType = sessionType; } public String getIdentifier() { @@ -121,6 +124,14 @@ public class SessionData { this.exception = exception; } + public String getSessionType() { + return sessionType; + } + + public void setSessionType(String sessionType) { + this.sessionType = sessionType; + } + @Override public boolean equals(Object o) { if (this == o) return true; diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/ApiUtils.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/ApiUtils.scala index dbdd34ead..7a0582613 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/ApiUtils.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/ApiUtils.scala @@ -36,7 +36,8 @@ object ApiUtils { session.createTime, session.lastAccessTime - session.createTime, session.getNoOperationTime, - session.getSessionEvent.flatMap(_.exception).map(Utils.prettyPrint).getOrElse("")) + session.getSessionEvent.flatMap(_.exception).map(Utils.prettyPrint).getOrElse(""), + session.sessionType.toString) } def operationData(operation: KyuubiOperation): OperationData = {