public boolean dealKeyPattern(String fieldRow, AbstractTableInfo tableInfo) {
        for (Map.Entry<String, Pattern> keyPattern : patternMap.entrySet()) {
            Pattern pattern = keyPattern.getValue();
            String key = keyPattern.getKey();
            Matcher matcher = pattern.matcher(fieldRow);
            if (matcher.find()) {
                ITableFieldDealHandler handler = handlerMap.get(key);
                if (handler == null) {
                    throw new RuntimeException("parse field [" + fieldRow + "] error.");
                }

                handler.dealPrimaryKey(matcher, tableInfo);
                return true;
            }
        }

        return false;
    }
Reason:
Date: 2018/7/4
Company: www.dtstack.com

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