We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cc2e993 commit b03eb57Copy full SHA for b03eb57
1 file changed
spark/src/main/scala/org/apache/comet/udf/ArrayExistsUDF.scala
@@ -45,7 +45,7 @@ import org.apache.comet.CometArrowAllocator
45
*/
46
class ArrayExistsUDF extends CometUDF {
47
48
- override def evaluate(inputs: Array[ValueVector]): ValueVector = {
+ override def evaluate(inputs: Array[ValueVector], numRows: Int): ValueVector = {
49
require(inputs.length == 2, s"ArrayExistsUDF expects 2 inputs, got ${inputs.length}")
50
val listVec = inputs(0).asInstanceOf[ListVector]
51
val keyVec = inputs(1).asInstanceOf[VarCharVector]
0 commit comments