diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizationContext.java ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizationContext.java index 16b45dd..c9c15bc 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizationContext.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizationContext.java @@ -869,7 +869,7 @@ private VectorExpression getVectorBinaryComparisonFilterExpression(String int inputCol2 = v2.getOutputColumn(); String scalarType = constDesc.getTypeString(); String colType = v2.getOutputType(); - String className = getFilterScalarColumnExpressionClassName(colType, + String className = getFilterColumnScalarExpressionClassName(colType, scalarType, opName); try { expr = (VectorExpression) Class.forName(className). @@ -950,21 +950,6 @@ private String getFilterColumnScalarExpressionClassName(String colType, String return b.toString(); } - private String getFilterScalarColumnExpressionClassName(String colType, String - scalarType, String opName) throws HiveException { - StringBuilder b = new StringBuilder(); - b.append("org.apache.hadoop.hive.ql.exec.vector.expressions.gen."); - if (opType.equals(OperatorType.FILTER)) { - b.append("Filter"); - } - b.append(getNormalizedTypeName(scalarType)); - b.append("Scalar"); - b.append(opName); - b.append(getNormalizedTypeName(colType)); - b.append("Column"); - return b.toString(); - } - private String getBinaryColumnScalarExpressionClassName(String colType, String scalarType, String method) throws HiveException { StringBuilder b = new StringBuilder();