From 991a968f3670c2d7d4ed081f7fd51e7244525cf8 Mon Sep 17 00:00:00 2001 From: Gengliang Wang Date: Fri, 26 Oct 2018 16:16:29 +0800 Subject: [PATCH 1/2] fix deprecated warning --- .../org/apache/spark/sql/execution/ui/SQLListener.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala index c04a31c428d1..e8840e0b458a 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala @@ -89,12 +89,12 @@ private class LongLongTupleConverter extends Converter[(Object, Object), (Long, } override def getInputType(typeFactory: TypeFactory): JavaType = { - val objectType = typeFactory.uncheckedSimpleType(classOf[Object]) - typeFactory.constructSimpleType(classOf[(_, _)], classOf[(_, _)], Array(objectType, objectType)) + val objectType = typeFactory.constructType(classOf[Object]) + typeFactory.constructSimpleType(classOf[(_, _)], Array(objectType, objectType)) } override def getOutputType(typeFactory: TypeFactory): JavaType = { - val longType = typeFactory.uncheckedSimpleType(classOf[Long]) - typeFactory.constructSimpleType(classOf[(_, _)], classOf[(_, _)], Array(longType, longType)) + val longType = typeFactory.constructType(classOf[(Long)]) + typeFactory.constructSimpleType(classOf[(_, _)], Array(longType, longType)) } } From 940ec4a09dbfeaa03bf2659ea779aa3603fff23d Mon Sep 17 00:00:00 2001 From: Gengliang Wang Date: Fri, 26 Oct 2018 22:56:36 +0800 Subject: [PATCH 2/2] address comment --- .../scala/org/apache/spark/sql/execution/ui/SQLListener.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala index e8840e0b458a..03d75c4c1b82 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala @@ -94,7 +94,7 @@ private class LongLongTupleConverter extends Converter[(Object, Object), (Long, } override def getOutputType(typeFactory: TypeFactory): JavaType = { - val longType = typeFactory.constructType(classOf[(Long)]) + val longType = typeFactory.constructType(classOf[Long]) typeFactory.constructSimpleType(classOf[(_, _)], Array(longType, longType)) } }