From f9f4e37bdfc8258e70616d82c70c8f60591cadf3 Mon Sep 17 00:00:00 2001
From: Huaxin Gao <huaxin_gao@apple.com>
Date: Mon, 16 Aug 2021 13:47:54 -0700
Subject: [PATCH] addess comments

---
 .../spark/sql/connector/catalog/index/SupportsIndex.java  | 8 ++++----
 .../sql/catalyst/analysis/AlreadyExistException.scala     | 4 ++--
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/index/SupportsIndex.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/index/SupportsIndex.java
index b2cb25c4cb71e..d0933bb865a07 100644
--- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/index/SupportsIndex.java
+++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/index/SupportsIndex.java
@@ -48,10 +48,10 @@ public interface SupportsIndex extends CatalogPlugin {
    * @throws UnsupportedOperationException If create index is not a supported operation
    */
   void createIndex(String indexName,
-                   String indexType,
-                   Identifier table,
-                   FieldReference[] columns,
-                   Map<String, String> properties)
+      String indexType,
+      Identifier table,
+      FieldReference[] columns,
+      Map<String, String> properties)
       throws IndexAlreadyExistsException, UnsupportedOperationException;
 
   /**
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlreadyExistException.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlreadyExistException.scala
index dd958e466fb65..ce48cfa89a389 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlreadyExistException.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlreadyExistException.scala
@@ -79,5 +79,5 @@ class PartitionsAlreadyExistException(message: String) extends AnalysisException
 class FunctionAlreadyExistsException(db: String, func: String)
   extends AnalysisException(s"Function '$func' already exists in database '$db'")
 
-class IndexAlreadyExistsException(indexName: String)
-  extends AnalysisException(s"Index '$indexName' already exists")
+class IndexAlreadyExistsException(indexName: String, table: Identifier)
+  extends AnalysisException(s"Index '$indexName' already exists in table ${table.quoted}")