This is an automated email from the ASF dual-hosted git repository.
ulyssesyou pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-kyuubi.git.
from dcc71b3 [KYUUBI #2207]Support newly added spark data types:
TimestampNTZType
add 6fe6975 [KYUUBI #1798] Add EventBus module to unify the distribution
and subscription of Kyuubi's events
No new revisions were added by this update.
Summary of changes:
.../kyuubi/engine/spark/SparkSQLEngine.scala | 45 +++++--
.../spark/events/SparkEventLoggingService.scala | 50 -------
.../handler/SparkHistoryLoggingEventHandler.scala} | 17 ++-
.../handler/SparkJsonLoggingEventHandler.scala | 25 ++--
.../engine/spark/operation/ExecuteStatement.scala | 6 +-
.../engine/spark/session/SparkSessionImpl.scala | 6 +-
.../apache/spark/kyuubi/SparkContextHelper.scala | 22 +---
.../SparkJsonLoggingEventHandlerSuite.scala} | 9 +-
.../events/AbstractEventLoggingService.scala | 59 ---------
.../scala/org/apache/kyuubi/events/EventBus.scala | 112 ++++++++++++++++
.../JsonLoggingEventHandler.scala} | 65 ++++------
.../{EventLogger.scala => handler/package.scala} | 6 +-
.../org/apache/kyuubi/events/EventBusSuite.scala | 144 +++++++++++++++++++++
.../handler/ServerJsonLoggingEventHandler.scala | 24 ++--
.../apache/kyuubi/operation/ExecuteStatement.scala | 6 +-
.../kyuubi/server/KyuubiEventLoggingService.scala | 50 -------
.../org/apache/kyuubi/server/KyuubiServer.scala | 37 +++++-
.../apache/kyuubi/session/KyuubiSessionImpl.scala | 8 +-
.../ServerJsonLoggingEventHandlerSuite.scala} | 5 +-
19 files changed, 396 insertions(+), 300 deletions(-)
delete mode 100644
externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SparkEventLoggingService.scala
copy
externals/kyuubi-spark-sql-engine/src/{test/scala/org/apache/spark/kyuubi/SparkSQLEngineListenerSuite.scala
=>
main/scala/org/apache/kyuubi/engine/spark/events/handler/SparkHistoryLoggingEventHandler.scala}
(64%)
copy dev/kyuubi-tpcds/src/main/scala/org/apache/spark/KyuubiSparkUtils.scala
=>
externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/handler/SparkJsonLoggingEventHandler.scala
(64%)
rename
externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/events/{SparkEventLoggingServiceSuite.scala
=> handler/SparkJsonLoggingEventHandlerSuite.scala} (95%)
delete mode 100644
kyuubi-common/src/main/scala/org/apache/kyuubi/events/AbstractEventLoggingService.scala
create mode 100644
kyuubi-common/src/main/scala/org/apache/kyuubi/events/EventBus.scala
rename
kyuubi-common/src/main/scala/org/apache/kyuubi/events/{JsonEventLogger.scala =>
handler/JsonLoggingEventHandler.scala} (72%)
rename
kyuubi-common/src/main/scala/org/apache/kyuubi/events/{EventLogger.scala =>
handler/package.scala} (91%)
create mode 100644
kyuubi-common/src/test/scala/org/apache/kyuubi/events/EventBusSuite.scala
copy dev/kyuubi-tpcds/src/main/scala/org/apache/spark/KyuubiSparkUtils.scala
=>
kyuubi-server/src/main/scala/org/apache/kyuubi/events/handler/ServerJsonLoggingEventHandler.scala
(68%)
delete mode 100644
kyuubi-server/src/main/scala/org/apache/kyuubi/server/KyuubiEventLoggingService.scala
rename
kyuubi-server/src/test/scala/org/apache/kyuubi/events/{KyuubiEventLoggingServiceSuite.scala
=> handler/ServerJsonLoggingEventHandlerSuite.scala} (98%)
