adjust code based on more commented rules

sql/core/src/main/scala/org/apache/spark/sql/execution/basicPhysicalOperators.scala

@@ -797,7 +797,7 @@ object SubqueryExec {
 /**
  * A wrapper for reused [[BaseSubqueryExec]].
  */
-case class ReusedSubqueryExec(override val child: BaseSubqueryExec)
+case class ReusedSubqueryExec(child: BaseSubqueryExec)
   extends BaseSubqueryExec with LeafExecNode {
 
   override def name: String = child.name

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

@@ -37,9 +37,9 @@ import org.apache.spark.sql.util.CaseInsensitiveStringMap
  * Rows in the output data set are appended.
  */
 case class AppendDataExecV1(
-    override val table: SupportsWrite,
-    override val writeOptions: CaseInsensitiveStringMap,
-    override val plan: LogicalPlan) extends V1FallbackWriters {
+    table: SupportsWrite,
+    writeOptions: CaseInsensitiveStringMap,
+    plan: LogicalPlan) extends V1FallbackWriters {
 
   override protected def doExecute(): RDD[InternalRow] = {
     writeWithV1(newWriteBuilder().buildForV1Write())

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

@@ -119,8 +119,8 @@ case class AtomicCreateTableAsSelectExec(
     catalog: StagingTableCatalog,
     ident: Identifier,
     partitioning: Seq[Transform],
-    override val plan: LogicalPlan,
-    override val query: SparkPlan,
+    plan: LogicalPlan,
+    query: SparkPlan,
     properties: Map[String, String],
     writeOptions: CaseInsensitiveStringMap,
     ifNotExists: Boolean) extends AtomicTableWriteExec {
@@ -153,8 +153,8 @@ case class ReplaceTableAsSelectExec(
     catalog: TableCatalog,
     ident: Identifier,
     partitioning: Seq[Transform],
-    override val plan: LogicalPlan,
-    override val query: SparkPlan,
+    plan: LogicalPlan,
+    query: SparkPlan,
     properties: Map[String, String],
     writeOptions: CaseInsensitiveStringMap,
     orCreate: Boolean) extends V2TableWriteExec with SupportsV1Write {
@@ -219,8 +219,8 @@ case class AtomicReplaceTableAsSelectExec(
     catalog: StagingTableCatalog,
     ident: Identifier,
     partitioning: Seq[Transform],
-    override val plan: LogicalPlan,
-    override val query: SparkPlan,
+    plan: LogicalPlan,
+    query: SparkPlan,
     properties: Map[String, String],
     writeOptions: CaseInsensitiveStringMap,
     orCreate: Boolean) extends AtomicTableWriteExec {
@@ -253,7 +253,7 @@ case class AtomicReplaceTableAsSelectExec(
 case class AppendDataExec(
     table: SupportsWrite,
     writeOptions: CaseInsensitiveStringMap,
-    override val query: SparkPlan) extends V2TableWriteExec with BatchWriteHelper {
+    query: SparkPlan) extends V2TableWriteExec with BatchWriteHelper {
 
   override protected def doExecute(): RDD[InternalRow] = {
     writeWithV2(newWriteBuilder().buildForBatch())
@@ -274,7 +274,7 @@ case class OverwriteByExpressionExec(
     table: SupportsWrite,
     deleteWhere: Array[Filter],
     writeOptions: CaseInsensitiveStringMap,
-    override val query: SparkPlan) extends V2TableWriteExec with BatchWriteHelper {
+    query: SparkPlan) extends V2TableWriteExec with BatchWriteHelper {
 
   private def isTruncate(filters: Array[Filter]): Boolean = {
     filters.length == 1 && filters(0).isInstanceOf[AlwaysTrue]

sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala

@@ -71,7 +71,7 @@ case class CollectLimitExec(limit: Int, child: SparkPlan) extends LimitExec {
  * This operator will be used when a logical `Tail` operation is the final operator in an
  * logical plan, which happens when the user is collecting results back to the driver.
  */
-case class CollectTailExec(override val limit: Int, child: SparkPlan) extends LimitExec {
+case class CollectTailExec(limit: Int, child: SparkPlan) extends LimitExec {
   override def output: Seq[Attribute] = child.output
   override def outputPartitioning: Partitioning = SinglePartition
   override def executeCollect(): Array[InternalRow] = child.executeTail(limit)
@@ -142,7 +142,7 @@ trait BaseLimitExec extends LimitExec with CodegenSupport {
 /**
  * Take the first `limit` elements of each child partition, but do not collect or shuffle them.
  */
-case class LocalLimitExec(override val limit: Int, child: SparkPlan) extends BaseLimitExec {
+case class LocalLimitExec(limit: Int, child: SparkPlan) extends BaseLimitExec {
 
   override def outputOrdering: Seq[SortOrder] = child.outputOrdering
 
@@ -152,7 +152,7 @@ case class LocalLimitExec(override val limit: Int, child: SparkPlan) extends Bas
 /**
  * Take the first `limit` elements of the child's single output partition.
  */
-case class GlobalLimitExec(override val limit: Int, child: SparkPlan) extends BaseLimitExec {
+case class GlobalLimitExec(limit: Int, child: SparkPlan) extends BaseLimitExec {
 
   override def requiredChildDistribution: List[Distribution] = AllTuples :: Nil
 

sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/statefulOperators.scala

@@ -427,10 +427,10 @@ case class StateStoreSaveExec(
 
 /** Physical operator for executing streaming Deduplicate. */
 case class StreamingDeduplicateExec(
-    override val keyExpressions: Seq[Attribute],
+    keyExpressions: Seq[Attribute],
     child: SparkPlan,
     stateInfo: Option[StatefulOperatorStateInfo] = None,
-    override val eventTimeWatermark: Option[Long] = None)
+    eventTimeWatermark: Option[Long] = None)
   extends UnaryExecNode with StateStoreWriter with WatermarkSupport {
 
   /** Distribute by grouping attributes */