We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a2b5408 commit 92e74a4Copy full SHA for 92e74a4
1 file changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Projection.scala
@@ -58,12 +58,12 @@ case class InterpretedMutableProjection(expressions: Seq[Expression]) extends Mu
58
private[this] var mutableRow: MutableRow = new GenericMutableRow(exprArray.size)
59
def currentValue: Row = mutableRow
60
61
- def target(row: MutableRow): MutableProjection = {
+ override def target(row: MutableRow): MutableProjection = {
62
mutableRow = row
63
this
64
}
65
66
- def apply(input: Row): Row = {
+ override def apply(input: Row): Row = {
67
var i = 0
68
while (i < exprArray.length) {
69
mutableRow(i) = exprArray(i).eval(input)
0 commit comments