public void setRowField(GenericRow row, Integer index, BaseSideInfo sideInfo, String value) {
        Integer keyIndex = sideInfo.getSideFieldIndex().get(index);
        String classType = sideInfo.getSideTableInfo().getFieldClassList().get(keyIndex).getName();
        switch (classType){
            case "java.lang.Integer":
                row.setField(index, Integer.valueOf(value));
                break;
            case "java.lang.String":
                row.setField(index, value);
                break;
            case "java.lang.Double":
                row.setField(index, Double.valueOf(value));
                break;
            case "java.lang.Long":
                row.setField(index, Long.valueOf(value));
                break;
            case "java.lang.Byte":
                row.setField(index, Byte.valueOf(value));
                break;
            case "java.lang.Short":
                row.setField(index, Short.valueOf(value));
                break;
            case "java.lang.Float":
                row.setField(index, Float.valueOf(value));
                break;
            case "java.math.BigDecimal":
                row.setField(index, BigDecimal.valueOf(Long.valueOf(value)));
                break;
            case "java.sql.Timestamp":
                row.setField(index, Timestamp.valueOf(value));
                break;
            case "java.sql.Date":
                row.setField(index, Date.valueOf(value));
                break;
            default:
                throw new RuntimeException("no support field type. the type: " + classType);
        }
    }
redis fill row data
Date: 2018/12/4
Company: www.dtstack.com
@author xuchao
redis5/redis5-side/redis-side-core/src/main/java/com/dtstack/flink/sql/side/redis/table/RedisSideReqRow.java