@Override
    public void buildEqualInfo(JoinInfo joinInfo, AbstractSideTableInfo sideTableInfo) {
        RdbSideTableInfo rdbSideTableInfo = (RdbSideTableInfo) sideTableInfo;
        List<String> selectFields = Lists.newArrayList();
        Map<String, String> physicalFields = rdbSideTableInfo.getPhysicalFields();
        physicalFields.keySet().forEach(
                item -> {
                    if (Objects.isNull(physicalFields.get(item))) {
                        selectFields.add(quoteIdentifier(item));
                    } else {
                        selectFields.add(quoteIdentifier(physicalFields.get(item)) + " AS " + quoteIdentifier(item));
                    }
                }
        );
        sqlCondition = getSelectFromStatement(getTableName(rdbSideTableInfo), selectFields, sideTableInfo.getPredicateInfoes());
        LOG.info("--------dimension sql query-------\n{}" + sqlCondition);
    }
Reason:
Date: 2018/11/26
Company: www.dtstack.com

@author maqi
rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/all/RdbAllSideInfo.java