public static KuduPredicate buildKuduPredicate(Schema schema, PredicateInfo info) {
        ColumnSchema column = schema.getColumn(info.getFieldName());
        Object value = "";
        switch (info.getOperatorKind()) {
            case "IN":
            case "NOT_IN":
            case "BETWEEN":
                value = Arrays.asList(StringUtils.split(info.getCondition(), ",")).stream()
                        .map(val -> KuduUtil.getValue(val.trim(), column.getType())).collect(Collectors.toList());
                break;
            case "IS_NOT_NULL":
            case "IS_NULL":
                break;
            default:
                value = KuduUtil.getValue(info.getCondition(), column.getType());
        }

        switch (info.getOperatorName()) {
            case "=":
                return KuduPredicate.newComparisonPredicate(column, KuduPredicate.ComparisonOp.EQUAL, value);
            case ">":
                return KuduPredicate.newComparisonPredicate(column, KuduPredicate.ComparisonOp.GREATER, value);
            case ">=":
                return KuduPredicate.newComparisonPredicate(column, KuduPredicate.ComparisonOp.GREATER_EQUAL, value);
            case "<":
                return KuduPredicate.newComparisonPredicate(column, KuduPredicate.ComparisonOp.LESS, value);
            case "<=":
                return KuduPredicate.newComparisonPredicate(column, KuduPredicate.ComparisonOp.LESS_EQUAL, value);
            case "IN":
                return KuduPredicate.newInListPredicate(column, (List) value);
            case "IS NOT NULL":
                return KuduPredicate.newIsNotNullPredicate(column);
            case "IS NULL":
                return KuduPredicate.newIsNullPredicate(column);
            default:
        }
        return null;

    }
util for kudu use
Date: 2019/12/16
Company: www.dtstack.com
@author maqi
kudu/kudu-side/kudu-side-core/src/main/java/com/dtstack/flink/sql/side/kudu/utils/KuduUtil.java