protected void dealNotNull(Matcher matcher, AbstractTableInfo tableInfo) {
        String fieldName = matcher.group(1);
        String fieldType = matcher.group(2);
        Class fieldClass= dbTypeConvertToJavaType(fieldType);
        AbstractTableInfo.FieldExtraInfo fieldExtraInfo = new AbstractTableInfo.FieldExtraInfo();
        fieldExtraInfo.setNotNull(true);

        tableInfo.addPhysicalMappings(fieldName, fieldName);
        tableInfo.addField(fieldName);
        tableInfo.addFieldClass(fieldClass);
        tableInfo.addFieldType(fieldType);
        tableInfo.addFieldExtraInfo(fieldExtraInfo);
    }
Reason:
Date: 2018/7/4
Company: www.dtstack.com

@author xuchao
core/src/main/java/com/dtstack/flink/sql/table/AbstractSourceParser.java