renaming variable

Author: ericm-db

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/metadata/StateMetadataSource.scala

@@ -46,18 +46,17 @@ case class StateMetadataTableEntry(
     numPartitions: Int,
     minBatchId: Long,
     maxBatchId: Long,
-    operatorProperties: String,
+    operatorPropertiesJson: String,
     numColsPrefixKey: Int) {
   def toRow(): InternalRow = {
-
     new GenericInternalRow(
       Array[Any](operatorId,
         UTF8String.fromString(operatorName),
         UTF8String.fromString(stateStoreName),
         numPartitions,
         minBatchId,
         maxBatchId,
-        UTF8String.fromString(operatorProperties),
+        UTF8String.fromString(operatorPropertiesJson),
         numColsPrefixKey
       ))
   }
@@ -226,7 +225,7 @@ class StateMetadataPartitionReader(
               stateStoreMetadata.numPartitions,
               if (batchIds.nonEmpty) batchIds.head else -1,
               if (batchIds.nonEmpty) batchIds.last else -1,
-              v2.operatorProperties,
+              v2.operatorPropertiesJson,
               stateStoreMetadata.numColsPrefixKey
             )
           }

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

@@ -115,7 +115,7 @@ object OperatorProperties {
 case class OperatorStateMetadataV2(
     operatorInfo: OperatorInfoV1,
     stateStoreInfo: Array[StateStoreMetadataV1],
-    operatorProperties: String) extends OperatorStateMetadata {
+    operatorPropertiesJson: String) extends OperatorStateMetadata {
   override def version: Int = 2
 }