[hotfix] Fix compile problem of InternalRow#getMap() interface in Spark connector

Author: wuchong

fluss-spark/fluss-spark-common/src/main/scala/org/apache/fluss/spark/row/SparkAsFlussArray.scala

@@ -17,10 +17,9 @@
 
 package org.apache.fluss.spark.row
 
-import org.apache.fluss.row.{BinaryString, Decimal, InternalArray => FlussInternalArray, InternalRow => FlussInternalRow, TimestampLtz, TimestampNtz}
-
+import org.apache.fluss.row.{BinaryString, Decimal, InternalMap, TimestampLtz, TimestampNtz, InternalArray => FlussInternalArray, InternalRow => FlussInternalRow}
 import org.apache.spark.sql.catalyst.util.{ArrayData => SparkArrayData}
-import org.apache.spark.sql.types.{ArrayType => SparkArrayType, DataType => SparkDataType, StructType}
+import org.apache.spark.sql.types.{StructType, ArrayType => SparkArrayType, DataType => SparkDataType}
 
 /** Wraps a Spark [[SparkArrayData]] as a Fluss [[FlussInternalArray]]. */
 class SparkAsFlussArray(arrayData: SparkArrayData, elementType: SparkDataType)
@@ -129,4 +128,9 @@ class SparkAsFlussArray(arrayData: SparkArrayData, elementType: SparkDataType)
   override def getRow(pos: Int, numFields: Int): FlussInternalRow =
     new SparkAsFlussRow(elementType.asInstanceOf[StructType])
       .replace(arrayData.getStruct(pos, numFields))
+
+  /** Returns the map value at the given position. */
+  override def getMap(pos: Int): InternalMap = {
+    throw new UnsupportedOperationException()
+  }
 }

fluss-spark/fluss-spark-common/src/main/scala/org/apache/fluss/spark/row/SparkAsFlussRow.scala

@@ -17,8 +17,7 @@
 
 package org.apache.fluss.spark.row
 
-import org.apache.fluss.row.{BinaryString, Decimal, InternalRow => FlussInternalRow, TimestampLtz, TimestampNtz}
-
+import org.apache.fluss.row.{BinaryString, Decimal, InternalMap, TimestampLtz, TimestampNtz, InternalRow => FlussInternalRow}
 import org.apache.spark.sql.catalyst.{InternalRow => SparkInternalRow}
 import org.apache.spark.sql.types.StructType
 
@@ -125,4 +124,8 @@ class SparkAsFlussRow(schema: StructType) extends FlussInternalRow with Serializ
     new SparkAsFlussRow(schema.fields(pos).dataType.asInstanceOf[StructType])
       .replace(row.getStruct(pos, numFields))
 
+  /** Returns the map value at the given position. */
+  override def getMap(pos: Int): InternalMap = {
+    throw new UnsupportedOperationException()
+  }
 }