java.util.concurrent.ExecutionException: java.lang.Exception: failed to compile: org.codehaus.commons.compiler.CompileException: Line 15, Column 9: Invalid character input "@" (character code 64)
public SpecificOrdering generate(org.apache.spark.sql.catalyst.expressions.Expression[] expr) {
return new SpecificOrdering(expr);
}
class SpecificOrdering extends org.apache.spark.sql.catalyst.expressions.codegen.BaseOrdering {
private org.apache.spark.sql.catalyst.expressions.Expression[] expressions;
public SpecificOrdering(org.apache.spark.sql.catalyst.expressions.Expression[] expr) {
expressions = expr;
}
@Override
public int compare(InternalRow a, InternalRow b) {
InternalRow i = null;
i = a;
boolean isNullA2;
long primitiveA3;
{
boolean isNull0 = i.isNullAt(2);
long primitive1 = isNull0 ? -1L : (i.getLong(2));
isNullA2 = isNull0;
primitiveA3 = primitive1;
}
i = b;
boolean isNullB4;
long primitiveB5;
{
boolean isNull0 = i.isNullAt(2);
long primitive1 = isNull0 ? -1L : (i.getLong(2));
isNullB4 = isNull0;
primitiveB5 = primitive1;
}
if (isNullA2 && isNullB4) {
} else if (isNullA2) {
return 1;
} else if (isNullB4) {
return -1;
} else {
int comp = (primitiveA3 > primitiveB5 ? 1 : primitiveA3 < primitiveB5 ? -1 : 0);
if (comp != 0) {
return -comp;
}
}
return 0;
}
}