addess comments

apache · Aug 16, 2021 · f9f4e37 · f9f4e37
1 parent b89b321
commit f9f4e37
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 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
@@ -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/...atalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlreadyExistException.scala b/...atalyst/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}")