public Queue<Object> getExeQueue(String exeSql, Set<String> sideTableSet, String scope) throws SqlParseException {

        LOG.info("----------exec original Sql----------");
        LOG.info(exeSql);

        Queue<Object> queueInfo = Queues.newLinkedBlockingQueue();
        SqlNode sqlNode = flinkPlanner.getParser().parse(exeSql);

        try {
            parseSql(sqlNode, sideTableSet, queueInfo, null, null, null, scope, Sets.newHashSet());
        }catch (WithoutTableNameException e){
            throw new WithoutTableNameException(e.getMessage()+ "\n==sql==\n"+ exeSql);
        }
        queueInfo.offer(sqlNode);
        return queueInfo;
    }
Parsing sql, obtain execution information dimension table
Date: 2018/7/24
Company: www.dtstack.com
@author xuchao
core/src/main/java/com/dtstack/flink/sql/side/SideSQLParser.java