lint

Author: szehon-ho

sql/catalyst/src/main/java/org/apache/spark/sql/connector/metric/MergeMetrics.java

@@ -18,6 +18,10 @@
 
 import java.util.OptionalLong;
 
+/**
+ * Execution metrics for a Merge Operation for a Connector that supports RowLevelOperations
+ * of this type.
+ */
 public interface MergeMetrics {
 
   /**

sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/BatchWrite.java

@@ -18,7 +18,6 @@
 package org.apache.spark.sql.connector.write;
 
 import org.apache.spark.annotation.Evolving;
-import org.apache.spark.sql.connector.metric.CustomTaskMetric;
 import org.apache.spark.sql.connector.metric.MergeMetrics;
 
 /**
@@ -108,7 +107,8 @@ default void onDataWriterCommit(WriterCommitMessage message) {}
   void abort(WriterCommitMessage[] messages);
 
   /**
-   * Similar to {@link #commit(WriterCommitMessage[])}, but providing merge exec metrics to this batch write.
+   * Similar to {@link #commit(WriterCommitMessage[])}, but providing merge exec metrics to
+   * this batch write.
    * @param metrics merge execution metrics
    */
   default void commitMerge(WriterCommitMessage[] messages, MergeMetrics metrics) {

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/WriteToDataSourceV2Exec.scala

@@ -425,7 +425,6 @@ trait V2TableWriteExec extends V2CommandExec with UnaryExecNode with AdaptiveSpa
         tempRdd
       }
     }
-
     // introduce a local var to avoid serializing the whole class
     val task = writingTask
     val writerFactory = batchWrite.createBatchWriterFactory(
@@ -456,7 +455,6 @@ trait V2TableWriteExec extends V2CommandExec with UnaryExecNode with AdaptiveSpa
       )
 
       val mergeMetricsOpt = getMergeMetrics(query)
-
       logInfo(log"Data source write support ${MDC(LogKeys.BATCH_WRITE, batchWrite)} is committing.")
       mergeMetricsOpt match {
         case Some(metrics) => batchWrite.commitMerge(messages, metrics)