Spark SQL Code Generation Example

GenerateAdd.scala

(() => {
  final class $anon extends org.apache.spark.sql.catalyst.expressions.MutableProjection {
    def <init>() = {
      super.<init>();
      ()
    };
    private[this] var mutableRow: org.apache.spark.sql.catalyst.expressions.MutableRow = new org.apache.spark.sql.catalyst.expressions.GenericMutableRow(1);
    def target(row: org.apache.spark.sql.catalyst.expressions.MutableRow): org.apache.spark.sql.catalyst.expressions.MutableProjection = {
      mutableRow = row;
      this
    };
    def currentValue: org.apache.spark.sql.catalyst.expressions.Row = mutableRow;
    def apply(i: org.apache.spark.sql.catalyst.expressions.Row): org.apache.spark.sql.catalyst.expressions.Row = {
      val nullTerm$4: Boolean = i.isNullAt(0);
      val primitiveTerm$3: org.apache.spark.sql.catalyst.types.IntegerType.JvmType = if (nullTerm$4)
        -1
      else
        i.getInt(0);
      ();
      val nullTerm$7: Boolean = i.isNullAt(1);
      val primitiveTerm$6: org.apache.spark.sql.catalyst.types.IntegerType.JvmType = if (nullTerm$7)
        -1
      else
        i.getInt(1);
      ();
      val nullTerm$1 = nullTerm$4.$bar$bar(nullTerm$7);
      val primitiveTerm$0: org.apache.spark.sql.catalyst.types.IntegerType.JvmType = if (nullTerm$1)
        -1
      else
        primitiveTerm$3.$plus(primitiveTerm$6).asInstanceOf[org.apache.spark.sql.catalyst.types.IntegerType.JvmType];
      ();
      if (nullTerm$1)
        mutableRow.setNullAt(0)
      else
        mutableRow.setInt(0, primitiveTerm$0);
      mutableRow
    }
  };
  new $anon()
})