@Override
	public AbstractTableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, Object> props) {
		ServersocketSourceTableInfo serversocketSourceTableInfo = new ServersocketSourceTableInfo();
		serversocketSourceTableInfo.setName(tableName);
		parseFieldsInfo(fieldsInfo, serversocketSourceTableInfo);

		serversocketSourceTableInfo.setHostname(MathUtil.getString(props.get(ServersocketSourceTableInfo.HOSTNAME_KEY.toLowerCase())));
		serversocketSourceTableInfo.setPort(MathUtil.getIntegerVal(props.get(ServersocketSourceTableInfo.PORT_KEY.toLowerCase())));
		serversocketSourceTableInfo.setDelimiter(MathUtil.getString(props.get(ServersocketSourceTableInfo.DELIMITER_KEY.toLowerCase())));
		serversocketSourceTableInfo.setMaxNumRetries(MathUtil.getLongVal(props.get(ServersocketSourceTableInfo.MAXNUMRETRIES_KEY.toLowerCase())));

		serversocketSourceTableInfo.check();

		return serversocketSourceTableInfo;
	}
Reason:
Date: 2018/12/18
Company: www.dtstack.com

@author maqi
serversocket/serversocket-source/src/main/java/com/dtstack/flink/sql/source/serversocket/table/ServersocketSourceParser.java