File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed
scala/org/apache/spark/sql/comet/util
spark-3.x/org/apache/comet/shims Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -223,9 +223,9 @@ object Utils extends CometTypeShim {
223223 writer.close()
224224
225225 if (out.size() > 0 ) {
226- (batch.numRows(), cbbos.toChunkedByteBuffer)
226+ (batch.numRows().toLong , cbbos.toChunkedByteBuffer)
227227 } else {
228- (batch.numRows(), new ChunkedByteBuffer (Array .empty[ByteBuffer ]))
228+ (batch.numRows().toLong , new ChunkedByteBuffer (Array .empty[ByteBuffer ]))
229229 }
230230 }
231231 }
Original file line number Diff line number Diff line change @@ -20,6 +20,9 @@ package org.apache.comet.shims
2020
2121import org .apache .spark .sql .types .DataType
2222
23+ import scala .annotation .nowarn
24+
2325trait CometTypeShim {
26+ @ nowarn // Spark 4 feature; stubbed to false in Spark 3.x for compatibility.
2427 def isStringCollationType (dt : DataType ): Boolean = false
2528}
You can’t perform that action at this time.
0 commit comments