private Map<String, String> parseColumnFamily(Map<String, String> physicalFieldMap){
        Map<String, String> columnFamiles = Maps.newLinkedHashMap();
        physicalFieldMap.values().forEach(x -> {
            String[] columnFamily = StringUtils.split(x.trim(), ":");
            columnFamiles.put(x, columnFamily[1]);
        });

        return columnFamiles;
    }
Date: 2018/09/14
Company: www.dtstack.com
@author sishu.yss
hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/table/HbaseSinkParser.java