public void dealPrimaryKey(Matcher matcher, AbstractTableInfo tableInfo) {
        String primaryFields = matcher.group(2).trim();
        List<String> primaryKeys = Arrays
                .stream(primaryFields.split(","))
                .map(String::trim)
                .collect(Collectors.toList());
        tableInfo.setPrimaryKeys(primaryKeys);
    }
Reason:
Date: 2018/7/4
Company: www.dtstack.com

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