From 8716c6eccf3d606a2c5f6275b8b3a9b343b01393 Mon Sep 17 00:00:00 2001 From: gatorsmile Date: Sun, 21 Jan 2018 08:24:51 -0800 Subject: [PATCH] fix --- .../spark/sql/catalyst/rules/QueryExecutionMetering.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/QueryExecutionMetering.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/QueryExecutionMetering.scala index a9379a91aa4da..62f7541150a6e 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/QueryExecutionMetering.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/QueryExecutionMetering.scala @@ -17,9 +17,10 @@ package org.apache.spark.sql.catalyst.rules -import com.google.common.util.concurrent.AtomicLongMap import scala.collection.JavaConverters._ +import com.google.common.util.concurrent.AtomicLongMap + case class QueryExecutionMetering() { private val timeMap = AtomicLongMap.create[String]() private val numRunsMap = AtomicLongMap.create[String]()