[SPARK-36457][DOCS] Review and fix issues in Scala/Java API docs

core/src/main/scala/org/apache/spark/SparkException.scala

@@ -72,7 +72,7 @@ private[spark] class SparkUpgradeException(version: String, message: String, cau
 /**
  * Arithmetic exception thrown from Spark with an error class.
  */
-class SparkArithmeticException(errorClass: String, messageParameters: Array[String])
+private[spark] class SparkArithmeticException(errorClass: String, messageParameters: Array[String])
   extends ArithmeticException(SparkThrowableHelper.getMessage(errorClass, messageParameters))
     with SparkThrowable {
 

core/src/main/scala/org/apache/spark/errors/SparkCoreErrors.scala

@@ -30,7 +30,7 @@ import org.apache.spark.storage.{BlockId, BlockManagerId, BlockNotFoundException
 /**
  * Object for grouping error messages from (most) exceptions thrown during query execution.
  */
-object SparkCoreErrors {
+private[spark] object SparkCoreErrors {
   def rddBlockNotFoundError(blockId: BlockId, id: Int): Throwable = {
     new Exception(s"Could not compute split, block $blockId of RDD $id not found")
   }

core/src/main/scala/org/apache/spark/io/MutableCheckedOutputStream.scala

@@ -24,7 +24,7 @@ import java.util.zip.Checksum
  * A variant of [[java.util.zip.CheckedOutputStream]] which can
  * change the checksum calculator at runtime.
  */
-class MutableCheckedOutputStream(out: OutputStream) extends OutputStream {
+private[spark] class MutableCheckedOutputStream(out: OutputStream) extends OutputStream {
   private var checksum: Checksum = _
 
   def setChecksum(c: Checksum): Unit = {

core/src/main/scala/org/apache/spark/scheduler/MiscellaneousProcessDetails.scala

@@ -16,14 +16,15 @@
  */
 package org.apache.spark.scheduler
 
-import org.apache.spark.annotation.DeveloperApi
+import org.apache.spark.annotation.{DeveloperApi, Since}
 
 /**
  * :: DeveloperApi ::
  * Stores information about an Miscellaneous Process to pass from the scheduler to SparkListeners.
  */
 
 @DeveloperApi
+@Since("3.2.0")
 class MiscellaneousProcessDetails(
     val hostPort: String,
     val cores: Int,

core/src/main/scala/org/apache/spark/scheduler/SparkListener.scala

@@ -228,6 +228,7 @@ case class SparkListenerUnschedulableTaskSetRemoved(
 case class SparkListenerBlockUpdated(blockUpdatedInfo: BlockUpdatedInfo) extends SparkListenerEvent
 
 @DeveloperApi
+@Since("3.2.0")
 case class SparkListenerMiscellaneousProcessAdded(time: Long, processId: String,
     info: MiscellaneousProcessDetails) extends SparkListenerEvent
 

core/src/main/scala/org/apache/spark/util/DependencyUtils.scala

@@ -29,7 +29,7 @@ import org.apache.spark.deploy.SparkSubmitUtils
 import org.apache.spark.internal.Logging
 import org.apache.spark.internal.config._
 
-case class IvyProperties(
+private[spark] case class IvyProperties(
     packagesExclusions: String,
     packages: String,
     repositories: String,

project/SparkBuild.scala

@@ -967,6 +967,7 @@ object Unidoc {
       .map(_.filterNot(_.getCanonicalPath.contains("org/apache/spark/sql/internal")))
       .map(_.filterNot(_.getCanonicalPath.contains("org/apache/spark/sql/hive")))
       .map(_.filterNot(_.getCanonicalPath.contains("org/apache/spark/sql/catalog/v2/utils")))
+      .map(_.filterNot(_.getCanonicalPath.contains("org.apache.spark.sql.errors")))
       .map(_.filterNot(_.getCanonicalPath.contains("org/apache/hive")))
       .map(_.filterNot(_.getCanonicalPath.contains("org/apache/spark/sql/v2/avro")))
       .map(_.filterNot(_.getCanonicalPath.contains("SSLOptions")))

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/FunctionCatalog.java

@@ -17,13 +17,17 @@
 
 package org.apache.spark.sql.connector.catalog;
 
+import org.apache.spark.annotation.Evolving;
 import org.apache.spark.sql.catalyst.analysis.NoSuchFunctionException;
 import org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException;
 import org.apache.spark.sql.connector.catalog.functions.UnboundFunction;
 
 /**
  * Catalog methods for working with Functions.
+ *
+ * @since 3.2.0
  */
+@Evolving
 public interface FunctionCatalog extends CatalogPlugin {
 
   /**

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TruncatableTable.java

@@ -21,6 +21,8 @@
 
 /**
  * Represents a table which can be atomically truncated.
+ *
+ * @since 3.2.0
  */
 @Evolving
 public interface TruncatableTable extends Table {

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/AggregateFunction.java

@@ -17,6 +17,7 @@
 
 package org.apache.spark.sql.connector.catalog.functions;
 
+import org.apache.spark.annotation.Evolving;
 import org.apache.spark.sql.catalyst.InternalRow;
 import org.apache.spark.sql.types.DataType;
 
@@ -42,7 +43,10 @@
  *
  * @param <S> the JVM type for the aggregation's intermediate state; must be {@link Serializable}
  * @param <R> the JVM type of result values
+ *
+ * @since 3.2.0
  */
+@Evolving
 public interface AggregateFunction<S extends Serializable, R> extends BoundFunction {
 
   /**

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/BoundFunction.java

@@ -17,6 +17,7 @@
 
 package org.apache.spark.sql.connector.catalog.functions;
 
+import org.apache.spark.annotation.Evolving;
 import org.apache.spark.sql.types.DataType;
 import org.apache.spark.sql.types.IntegerType;
 import org.apache.spark.sql.types.StructType;
@@ -25,7 +26,10 @@
 
 /**
  * Represents a function that is bound to an input type.
+ *
+ * @since 3.2.0
  */
+@Evolving
 public interface BoundFunction extends Function {
 
   /**

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/Function.java

@@ -17,11 +17,16 @@
 
 package org.apache.spark.sql.connector.catalog.functions;
 
+import org.apache.spark.annotation.Evolving;
+
 import java.io.Serializable;
 
 /**
  * Base class for user-defined functions.
+ *
+ * @since 3.2.0
  */
+@Evolving
 public interface Function extends Serializable {
 
   /**

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/ScalarFunction.java

@@ -17,6 +17,7 @@
 
 package org.apache.spark.sql.connector.catalog.functions;
 
+import org.apache.spark.annotation.Evolving;
 import org.apache.spark.sql.catalyst.InternalRow;
 import org.apache.spark.sql.types.DataType;
 
@@ -133,7 +134,10 @@
  *
  * @param <R> the JVM type of result values, MUST be consistent with the {@link DataType}
  *          returned via {@link #resultType()}, according to the mapping above.
+ *
+ * @since 3.2.0
  */
+@Evolving
 public interface ScalarFunction<R> extends BoundFunction {
   String MAGIC_METHOD_NAME = "invoke";
 

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/UnboundFunction.java

@@ -17,11 +17,15 @@
 
 package org.apache.spark.sql.connector.catalog.functions;
 
+import org.apache.spark.annotation.Evolving;
 import org.apache.spark.sql.types.StructType;
 
 /**
  * Represents a user-defined function that is not bound to input types.
+ *
+ * @since 3.2.0
  */
+@Evolving
 public interface UnboundFunction extends Function {
 
   /**

sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReportsSourceMetrics.java

@@ -25,6 +25,8 @@
 /**
  * A mix-in interface for {@link SparkDataStream} streaming sources to signal that they can report
  * metrics.
+ *
+ * @since 3.2.0
  */
 @Evolving
 public interface ReportsSourceMetrics extends SparkDataStream {

sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryCompilationErrors.scala

@@ -46,7 +46,7 @@ import org.apache.spark.sql.types._
  * As commands are executed eagerly, this also includes errors thrown during the execution of
  * commands, which users can see immediately.
  */
-private[spark] object QueryCompilationErrors {
+object QueryCompilationErrors {
 
   def groupingIDMismatchError(groupingID: GroupingID, groupByExprs: Seq[Expression]): Throwable = {
     new AnalysisException(

sql/catalyst/src/main/scala/org/apache/spark/sql/types/UDTRegistration.scala

@@ -19,7 +19,7 @@ package org.apache.spark.sql.types
 
 import scala.collection.mutable
 
-import org.apache.spark.annotation.DeveloperApi
+import org.apache.spark.annotation.{DeveloperApi, Since}
 import org.apache.spark.internal.Logging
 import org.apache.spark.sql.errors.QueryExecutionErrors
 import org.apache.spark.util.Utils
@@ -31,6 +31,7 @@ import org.apache.spark.util.Utils
  * alternative approach to register UDTs for user classes.
  */
 @DeveloperApi
+@Since("3.2.0")
 object UDTRegistration extends Serializable with Logging {
 
   /** The mapping between the Class between UserDefinedType and user classes. */

sql/catalyst/src/main/scala/org/apache/spark/sql/types/UserDefinedType.scala

@@ -22,7 +22,7 @@ import java.util.Objects
 import org.json4s.JsonAST.JValue
 import org.json4s.JsonDSL._
 
-import org.apache.spark.annotation.DeveloperApi
+import org.apache.spark.annotation.{DeveloperApi, Since}
 
 /**
  * The data type for User Defined Types (UDTs).
@@ -38,6 +38,7 @@ import org.apache.spark.annotation.DeveloperApi
  * The conversion via `deserialize` occurs when reading from a `DataFrame`.
  */
 @DeveloperApi
+@Since("3.2.0")
 abstract class UserDefinedType[UserType >: Null] extends DataType with Serializable {
 
   /** Underlying storage type for this UDT */

sql/core/src/main/java/org/apache/spark/sql/connector/write/V1Write.java

@@ -26,6 +26,8 @@
  * <p>
  * Tables that have {@link TableCapability#V1_BATCH_WRITE} in the list of their capabilities
  * must build {@link V1Write}.
+ *
+ * @since 3.2.0
  */
 @Unstable
 public interface V1Write extends Write {